RxJava学习之创建型操作符

下方展示了几种创建Observable的方法

  • just() ---将一个或者多个对象转换成发射这个或这些对象的一个Observable
  • from() --- 将一个Iterable,一个Future,或者一个数组转换成一个Observable
  • repeat() --- 创建一个重复发射指定数据或者数据序列的Observable
  • repeatWhean()---创建一个重复发射指定数据或数据序列的Observable,它依赖于另一个Observable发射的数据
  • create()---使用一个函数从头创建一个Observable
  • defer()---只有当订阅者订阅才能创建Observable;为每个订阅创建一个新的Observable
  • range()---创建一个发射指定范围的整数序列的Observable
  • interval()---创建一个按照给定的延时之后发射单个数据的Observable
  • timer()---创建一个在给定的延时之后发射单个数据的Observable
  • empty()---创建一个什么都不做的直接通知完成的Observable
  • error()---创建一个什么都不做直接通知错误的Observable
  • never()---创建一个不发射任何数据的Observable

create操作符

crate操作符是所有创建型操作符的根,也就是说其他创建型的操作符最后都是通过create操作符来创建Observable

  • 你可以使用Create操作符从头开始创建一个Observable，给这个操作符传递一个接受观察者作为参数的函数，编写这个函数让它的行为表现为一个Observable--恰当的调用观察者的onNext，onError和onCompleted方法。

  • 一个形式正确的有限Observable必须尝试调用观察者的onCompleted正好一次或者它的onError正好一次，而且此后不能再调用观察者的任何其它方法。


defer操作符

  • Defer操作符会一直等待直到有观察者订阅它，然后它使用Observable工厂方法生成一个Observable。它对每个观察者都这样做，因此尽管每个订阅者都以为自己订阅的是同一个Observable，事实上每个订阅者获取的是它们自己的单独的数据序列。

  • 在某些情况下，等待直到最后一分钟（就是知道订阅发生时）才生成Observable可以确保Observable包含最新的数据。

  • defer操作符默认不在任何调度器上执行

    /**
     * Defer
     * Defer操作符只有当有Subscriber来订阅的时候才会创建一个新的Observable对象,
     */
    private static void test(){
        
        Observable.defer(new Func0<Observable<Long>>() {

             //注意此处的call方法没有Subscriber参数,而create操作符有Subscriber参数
            @Override
            public Observable<Long> call() {
                return Observable.just(System.currentTimeMillis());
            }
        })
        .subscribe(new Subscriber<Long>() {
            
            @Override
            public void onCompleted() {
                System.out.println("onCompleted");      
            }
            
            @Override
            public void onNext(Long value) {
                System.out.println("onSuccess value = " + value);
            }
            
            @Override
            public void onError(Throwable error) {
                System.out.println("onError error = " + error);
            }
        });
        
    }

Just操作符

  • Just将单个数据转换为发射那个数据的Observable。

  • Just类似于From，但是From会将数组或Iterable的数据取出然后逐个发射，而Just只是简单的原样发射，将数组或Iterable当做单个数据。

注意：如果你传递null给Just，它会返回一个发射null值的Observable。不要误认为它会返回一个空Observable（完全不发射任何数据的Observable），如果需要空Observable你应该使用Empty操作符。

  • RxJava将这个操作符实现为just函数，它接受一至九个参数，返回一个按参数列表顺序发射这些数据的Observable。
/**
     * Just
     * Just操作符将某个对象转化为Observable对象，并且将其发射出去，可以使一个数字、
     * 一个字符串、数组、Iterate对象等，是一种非常快捷的创建Observable对象的方法，在以后的例子里会大量使用。
     */
    private static void test(){
        
        Observable.just(System.currentTimeMillis())
        .subscribe(new Subscriber<Long>() {
            
            @Override
            public void onCompleted() {
                System.out.println("onCompleted");      
            }
            
            @Override
            public void onNext(Long value) {
                System.out.println("onSuccess value = " + value);
            }
            
            @Override
            public void onError(Throwable error) {
                System.out.println("onError error = " + error);
            }
        });
        
    }

Defer和just操作符区别

    public static Observable<Long> DeferObservable() {
        return Observable.defer(new Func0<Observable<Long>>() {

            @Override
            public Observable<Long> call() {
                return Observable.just(System.currentTimeMillis());
            }
            
        });
    }

    public static Observable<Long> JustObservable() {
        return Observable.just(System.currentTimeMillis());
    }
    
    public static Observable<Long> deferObservable =  DeferObservable();
    public static Observable<Long> justObservable =  JustObservable();

    /**
     * Defer、Just区别
     * Defer:每次订阅都会得到一个刚创建的最新的Observable对象，这可以确保Observable对象里的数据是最新的;
     * Just:每次订阅不会创建的新的Observable对象
     */
    private static void test(){
        
        deferObservable.subscribe(new Observer<Long>() {
            
            @Override
            public void onCompleted() {
                System.out.println("onCompleted");      
            }
            
            @Override
            public void onNext(Long value) {
                SimpleDateFormat  sdf =new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");
                System.out.println("defer onSuccess value = " + sdf.format(new Date(value)));
            }
            
            @Override
            public void onError(Throwable error) {
                System.out.println("onError error = " + error);
            }
        });
        
        justObservable.subscribe(new Observer<Long>() {
            
            @Override
            public void onCompleted() {
                System.out.println("onCompleted");      
            }
            
            @Override
            public void onNext(Long value) {
                SimpleDateFormat  sdf =new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");
                System.out.println("just onSuccess value = " + sdf.format(new Date(value)));
            }
            
            @Override
            public void onError(Throwable error) {
                System.out.println("onError error = " + error);
            }
        });
        
    }

Interval操作符

创建一个按固定时间间隔发射整数序列的Observable


/**
     * Interval
     * Interval所创建的Observable对象会从0开始，每隔固定的时间(long interval)发射一个数字。
     * 需要注意的是这个对象是运行在computation Scheduler,所以如果需要在view中显示结果，要在主线程中订阅。
     */
    private static void test5(){
        
        Observable.interval(1, TimeUnit.SECONDS,Schedulers.immediate())
        .subscribe(new Subscriber<Long>() {
            
            @Override
            public void onCompleted() {
                System.out.println("onCompleted");      
            }
            
            @Override
            public void onNext(Long value) {
                SimpleDateFormat  sdf =new SimpleDateFormat("HH时mm分ss秒");
                System.out.println("onSuccess value = "+ value +  ", 现在时间：" + sdf.format(new Date()));
            }
            
            @Override
            public void onError(Throwable error) {
                System.out.println("onError error = " + error);
            }
        });
        
    }
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

  • RxJava操作符（一）
    注：只包含标准包中的操作符，用于个人学习及备忘参考博客：http://blog.csdn.net/maplejaw...
    小白要超神阅读 2,230评论 2赞 8
  • RxJava操作符大全
    作者： maplejaw本篇只解析标准包中的操作符。对于扩展包，由于使用率较低，如有需求，请读者自行查阅文档。 创...
    maplejaw_阅读 45,821评论 8赞 93
  • RxJava操作符（二）
    注：只包含标准包中的操作符，用于个人学习及备忘参考博客：http://blog.csdn.net/maplejaw...
    小白要超神阅读 969评论 0赞 3
  • RxJava常用操作符
    创建unfaseCreate(create)创建一个Observable（被观察者），当被观察者（Observer...
    chuwe1阅读 7,035评论 3赞 8
  • RxJava (源码待续)学习之创建操作符
    Today，学习RxJava 的操作符，首先献出官方文档 0 。操作符比较多，我们学习重要的常用的就好啦，就按照官...
    yoosir阅读 369评论 0赞 0