美文网首页手写rxjava
Rxjava2操作符 —— 手写操作符(一)

Rxjava2操作符 —— 手写操作符(一)

作者: 设计失 | 来源:发表于2019-03-14 20:32 被阅读0次

    RxJava2 在项目中使用频繁,导致每做一个逻辑操作都想着能不能用操作符来代替,虽然会增加写代码的时间,但是后续维护起来将非常方便;这里不演示使用RxJava2前和使用后的代码,网上有很多大牛都写了demo来表达对RxJava2的喜爱

    看懂RxJava2的前提 <泛型>

    说到看源码,相信很多小伙伴都热情满满的点开了 External Libraries中源码,但是点开之后看到的却是像这样:

    @CheckReturnValue
    @NonNull
    @SchedulerSupport(SchedulerSupport.NONE)
    public static <T> Observable<T> create(ObservableOnSubscribe<T> source) {
        ObjectHelper.requireNonNull(source, "source is null");
        return RxJavaPlugins.onAssembly(new ObservableCreate<T>(source));
    }
    

    或者是这样:

    @CheckReturnValue
    @NonNull
    @SchedulerSupport(SchedulerSupport.NONE)
    public static <T> Observable<T> defer(Callable<? extends ObservableSource<? extends T>> supplier) {
        ObjectHelper.requireNonNull(supplier, "supplier is null");
        return RxJavaPlugins.onAssembly(new ObservableDefer<T>(supplier));
    

    的代码,我刚开始使用RxJava2的时候,看到这样的代码是直接关闭当前窗口的,因为这是啥啊?

    这是啥?

    带着疑问,我们看到了 <? extends ObservableSource<? extends T>>这样复杂的泛型;说到泛型,大家都很熟悉,也很自信的想着我使用过,不就是这样:

    List<String> list = new Array<>();
    

    或者在类中:

    class BaseData<T> {
        int code;
        String message;
        T data;
    }
    

    是不是很熟悉?我们网络请求从后台拿到数据之后,一般都是自定义一个javabean和后台一样的字段,因为codemessage是不变的字段,而data数据则是根据不同的接口返回不同的数据,这里的T是一个泛型,你可以传入简单的数据类型StringInteger,也可以传入复杂的javabeanList<Class>类型等等,

    疑问解答:extendssuper使用在泛型中代表啥

    extends我们经常使用在类中继承、抽象
    super我们经常使用在方法中重载

    而当两者使用在泛型中时,表示一种界限设定,例如大神们经常举的例子:

    我们这里有水果、苹果(继承自水果):

    class Fruit(){}
    
    class Apple extends Fruit(){}
    

    然后有一个盘子来装东西:

    class Plate<T> {
        private T t;
        
        public Plate(T t) {
            this.t = t;
        }
        public T getT() {
            return t;
        }
        public void setT(T t) {
            this.t = t;
        }
    }
    

    现在有一个盘子来装水果,

    Plate<Fruit> plate = new Plate<Apple>(new Apple());
    

    在我们人为逻辑上,这是行得通的,但是在编译器上,却直接报错:

    imcompatible types:
    Required: Plate<Fruit>
    Found:Plate<Apple>
    

    为什么会有这样的错?

    编译器是这样认为的: 苹果是水果,但是装水果的盘子并不等于装苹果的盘子,这两者并不同;因为苹果是继承自水果的,但是盘子并没有继承关系。

    有了这样的问题,所以jdk出了<? extends T><? super T>,这样就让两个盘子之间发生了关系。

    疑问解答一:<? extends T> 代表什么?

    <? extends T>按照术语来说就是上界通配符,怎么说?

    按照我们上面的例子,Plate<? extends Fruit>, 一个能装水果、或者是只要继承自Fruit类的子类,它都可以用来装,通俗点讲:这个盘子可以装所有的水果了,不管是苹果还是香蕉;

    所以,上面报错的信息就可以改成这样:

    Plate<? extends Fruit> p = new Plate<Apple>(new Apple());
    

    那这个上界的意思就很清楚了,这个盘子能装苹果、香蕉;但是它最多就只能装水果,如果我们还有其他的比如包菜、萝卜之类的蔬菜我们这个装水果的盘子就无能为力了。

    疑问解答二:<? super T> 代表什么?

    <? super T>按照术语来说就是下界通配符,怎么说?
    按照上面的例子, Plate<? super Fruit>, 一个能装水果、或者是水果父类的盘子;很简单,只要是Fruit的父类,比如有一个类是Fruit的父类Food, 则下界则表示这个盘子只能能装水果和装食物。

    Plate<? super Fruit> p1 = new Plate<>(new Fruit());
    

    上面的意思是只要这个物品是只要是Fruit的的父类才能被装在盘子中,如果是这样编译器则报错:
    Plate<? super Fruit> p2 = new Plate<Apple>(new Apple());

    疑问解答三:<? super T><? extends T>的区别在哪?

    上界<? extends T>只能取,不能存:
    Plate<? extends Fruit> p = new Plate<Apple>(new Apple());
    Apple apple = (Apple) p.getT();
    

    而如果是存的话,编译器则直接报错:
    p.setT(new Apple());
    setT(capture<? extends Fruit>) in Plate can not be applied to (Apple)

    下界<? super T>只能存,不能取:
    Plate<? super Fruit> p1 = new Plate<Fruit>(new Fruit());
    p1.setT(new Apple());
    Object t = p1.getT();
    

    上面取出来是直接放到Object中,万物皆对象,但是如果是这样则是错的:
    Apple apple1 = (Apple) p1.getT();
    Imcompatible Types: Required Fruit; Found:capture<? super Fruit>

    总结

    PECS原则(Producer Extends Consumer Super):

    频繁往外读取内容的,适合用上界Extends。
    经常往里插入的,适合用下界Super。

    相关文章

      网友评论

        本文标题:Rxjava2操作符 —— 手写操作符(一)

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