zoukankan      html  css  js  c++  java
  • RXJAVA之创建被观察者

      RXJava中提供了多种创建数据源的方式

    使用create方法

    Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>(){
       @Override
       public void subscribe(ObservableEmitter<String> arg0) throws Exception {
        arg0.onNext("123");
        arg0.onComplete();
       }});

      通过create创建Observable,通过ObservableEmitter来发送消息。

    使用fromArray方法:

    Observable<String> observable = Observable.fromArray("123","456");

       通过fromArray快捷创建Observable,其会把参数通过onNext发送,最后执行onComplete方法。

    使用just方法:

    Observable<String> observable = Observable.just("123", "456");

      通过just快捷创建Observable,其效果与fromArray一样,底层通过fromArray实现。

    使用empty方法:

      创建一个什么都不做直接通知完成的Observable。

    使用error方法:

      创建一个什么都不做直接通知错误的Observable。

    使用timer方法:

      创建一个在给定的延时之后发射数据项为0的Observable<Long>。

    Observable<Long> observable = Observable.timer(5, TimeUnit.SECONDS);

    使用interval方法:

      创建一个按照给定的时间间隔发射从0开始的整数序列的Observable<Long>。

    Observable<Long> observable = Observable.interval(1, TimeUnit.SECONDS);

    使用range方法:

      创建一个发射指定范围的整数序列的Observable<Integer>

    Observable<Integer> observable = Observable.range(1, 10);

    使用defer方法:

    Observable<String> observable = Observable.defer(new Callable<ObservableSource<String>>(){
       @Override
       public ObservableSource<String> call() throws Exception {
        return Observable.just("123", "456");
       }});

      在订阅时通过callable创建一个Observable,为每个订阅的Observer创建一个单独的Observable。

  • 相关阅读:
    函数与方法(方法前 +
    1362 : 修补木桶 -- 最长的最短边
    149. Max Points on a Line *HARD* 求点集中在一条直线上的最多点数
    148. Sort List -- 时间复杂度O(n log n)
    133. Clone Graph 138. Copy List with Random Pointer 拷贝图和链表
    debug && release
    静态库 && 动态库
    枚举
    获取当前用户所使用的是什么浏览器
    java实现在图片上编辑文本内容
  • 原文地址:https://www.cnblogs.com/zhangwanhua/p/7591086.html
Copyright © 2011-2022 走看看