关于java:Android进阶学习RxJava二Observer升级版Subscriber

7次阅读

共计 1092 个字符,预计需要花费 3 分钟才能阅读完成。

Subscriber 翻译过去是订阅者
其实是 Observer 的升级版,加了一个 onStart 办法,改改名字

  • 开始编故事
小明 (Subscriber) 是个宅男,喜爱在家里读杂志
  • 所以小明订了一份纨绔子弟杂志

先介绍宅男小明(Subscriber)

  • 其余三个办法介绍在上一篇文章里有,不明所以的能够往上翻,看第一篇小明的故事
Subscriber <String> subscriber=new Subscriber<String>() {
    @Override // 新办法 小明喜爱看杂志前把纸拿到桌旁
    public void onStart() {super.onStart();
    }
    @Override 
    public void onCompleted() {LogUtils.e("Completed");
    }
    @Override
    public void onError(Throwable e) {LogUtils.e("Error");
    }
    @Override
    public void onNext(String s) {LogUtils.e(s);
    }
};

在介绍将来送报员(Observable)

  • 送报员有好多状态,上一篇应用的是原始状态

    • 应用 Observable.Create()创立的 Observable
  • 送报员的其余状态

    • Observable.just()创立被观察者
    • Observable.from()创立被观察者
OK 一个一个来
  • 送报学会了特技,发射模式,指标,小明的窗户
just
  • just 原样发射 不带包装,杂志间接丢进小明窗户

    • 每个参数发一遍,参数最多为 9 个,可为 null
Observable observable = Observable.just("Hello", "World");
from
  • 用来发送一个数组,先上源码
 public static <T> Observable<T> from(T[] array) {
        int n = array.length;
        if (n == 0) {return empty();
        } else
        if (n == 1) {return just(array[0]);
        }
        return create(new OnSubscribeFromArray<T>(array));
    }
  • 能够了解为,送报员开着火车送报,整车干到小明家
String [] words = {"Hello", "World"};
Observable observable = Observable.from(words);

最初,最重要的一步

  • 两个肯定要关联起来, 才会无效

    • 了解为,小明必须付钱,能力看到纨绔子弟
observable.subscribe(subscriber);

总结

  • 发简略小数据,用 just 简略粗犷
  • 数组类大量数据,用 from
正文完
 0