美文网首页
Java 泛型之 RxJava中的使用实例代码

Java 泛型之 RxJava中的使用实例代码

作者: 行走中的3卡 | 来源:发表于2022-04-07 17:10 被阅读0次

Java 泛型在RxJava 中的使用,网上有很多文章介绍,内容都差不多,不知道谁才是原创-_-
关键是给出的实例代码,都是不完整的,对于不好理解。
于是有了下文的自己写的完整代码。
(RxJava 是 观察者模式 的更高级的应用, 通过以下自定义的Observable 及其 map/ doOnNext操作,可以更好的理解RxJava框架的实现方式 )

1. 被观察的类 (对象)

仅是两个简单的Student 和 Teacher 类, 作用先不管

public class Student {
}
public class Teacher {
}

2.被观察者接口

2.1 将泛型声明放在接口或类

//将泛型声明放在接口
public interface Observable<T> {
    public T call();

    // 转换为另一类型R
    <R> Observable<R> map(Func1<T,R> fun1);

    // 下一步操作(链式调用)
    Observable<T> doOnNext(Action<T> action);
}

转换接口:

public interface Func1<T, R> {
    R call(T t);
}

链式调用

public interface Action <T>{
    void callAction(T t);
}

2.2 将泛型声明放在方法

//将泛型声明放在方法
public interface Observable2 {
    <T> T call(T t);
}

3.被观察者实现类

3.1 将泛型声明放在接口或类

//泛型声明在接口或类上,则类或接口中的方法均可使用T类型
public class ImplObservable<T> implements Observable<T> {
    T t;
    public ImplObservable(T t){
        this.t = t;
    }

    public static <T> ImplObservable<T> create (T t) {
        return new ImplObservable<>(t);
    }

    public ImplObservable(){
    }

    @Override
    public T call() {
        // TODO Auto-generated method stub
        System.out.println("ImplObservable call");
        return null;
    }

    //类型转换
    @Override
    public <R> Observable<R> map(Func1<T, R> fun1) {
        Observable<R> ob = ImplObservable.create(fun1.call(t));
        return ob;// 改变被观察着
    }

    //链式调用
    @Override
    public Observable<T> doOnNext(Action<T> action) {
        action.callAction(t);
        return this; // 被观察着不变
    }
}

3.2 将泛型声明放在方法

//泛型声明在方法上,则除去该声明有T泛型的方法之外,其他方法不识别T类型
public class ImplObservable2 implements Observable2{
    @Override
    public <T> T call(T t) {
        // TODO Auto-generated method stub
        System.out.println("ImplObservable2 call");
        return null;
    }
}

4. 测试代码

    public static void main(String args[]) {
        System.out.println("Hello RxJavaSample");
        //1. 将泛型声明在接口上或声明在类上
        System.out.println("------------RxJavaSample 1. 泛型类、接口 -------");
        Observable<Student> observer = new ImplObservable<Student>();
        Student student = observer.call();
        //2. 将泛型声明在方法上
        System.out.println("------------RxJavaSample 2. 泛型方法 -------");
        ImplObservable2 Observable2 = new ImplObservable2();
        Student student2 = Observable2.call(new Student());

        System.out.println("------------RxJavaSample 2-2. 泛型之构造函数的 类型安全 问题 -------");
        //3. 尝试向泛型在类上的 构造函数 传递 实际类型的 参数  (提示类型安全 警告??)
//        ImplObservable<Student> observable3 = new ImplObservable(new Student());
//        observable3.call();

        ImplObservable<Student> observable4 = ImplObservable.create(new Student());
        observable4.call();

        System.out.println("------------RxJavaSample 3. 类型转换 及 链式调用-------");
        Student student3 = new Student();
        Teacher teacher = new Teacher();
        ImplObservable.create(student3)
                .map(new Func1<Student, Teacher>() {
                    @Override
                    public Teacher call(Student student) {

                        System.out.println("student hashCode: " + student);
                        System.out.println("teacher hashCode: " + teacher);
                        return teacher;
                    }
                })
                .doOnNext(new Action<Teacher>() {
                    @Override
                    public void callAction(Teacher teacher) {
                        System.out.println("teacher hashCode: " + teacher);
                    }
                });
        System.out.println("------------RxJavaSample end--------");
    }

输出结果:

Hello RxJavaSample
------------RxJavaSample 1. 泛型类、接口 -------
ImplObservable call
------------RxJavaSample 2. 泛型方法 -------
ImplObservable2 call
------------RxJavaSample 2-2. 泛型之构造函数的 类型安全 问题 -------
ImplObservable call
------------RxJavaSample 3. 类型转换 及 链式调用-------
student hashCode: com.example.javalearnproject.Student@34ce8af7
teacher hashCode: com.example.javalearnproject.Teacher@b684286
teacher hashCode: com.example.javalearnproject.Teacher@b684286
------------RxJavaSample end--------

参考:
从RxJava中深入理解泛型,从学习泛型的过程中深入理解RxJava(一) - 简书 (jianshu.com)
如何深入理解Java泛型 - 知乎 (zhihu.com)

相关文章

网友评论

      本文标题:Java 泛型之 RxJava中的使用实例代码

      本文链接:https://www.haomeiwen.com/subject/lmlssrtx.html