RxJava 常用操作符大全（一）

作者: 花前月下的细说 | 来源:发表于2016-11-18 13:59 被阅读347次

RxJava
RxJava 常用操作符大全（一）
RxJava 常用操作符大全（二）
RxJava操作符系列四
RxJava操作符系列五
RxJava操作符系列六
RxJava2 中常用操作符和Subject常用子类说明
RxJava常用操作符
RxJava操作符系列三
RxJava进阶一（创建类操作符）

这里写图片描述

create

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

调用例子如下：

Observable.create(new Observable.OnSubscribe<Integer>() {
@Override
public void call(Subscriber<? super Integer> observer) {
try {
if (!observer.isUnsubscribed()) {
for (int i = 1; i < 5; i++) {
observer.onNext(i);
}
observer.onCompleted();
}
        } catch (Exception e) {
observer.onError(e);
}
    }
} ).subscribe(new Subscriber<Integer>() {
@Override
public void onNext(Integer item) {
System.out.println("Next: " + item);
}

@Overridepublicvoid onError(Throwable error) {
System.err.println("Error: " + error.getMessage());
}

@Overridepublicvoid onCompleted() {
System.out.println("Sequence complete.");
}
});

运行结果如下：

    Next: 1 
    Next: 2 
    Next: 3 
    Next: 4 
    Sequence complete.

from

from操作符是把其他类型的对象和数据类型转化成Observable

调用例子如下：

Integer[] items = { 0, 1, 2, 3, 4, 5 };
Observable myObservable = Observable.from(items);

myObservable.subscribe(
new Action1<Integer>() {
@Override
publicvoid call(Integer item) {
System.out.println(item);
}
},
        new Action1<Throwable>() {
@Override
publicvoid call(Throwable error) {
System.out.println("Error encountered: " + error.getMessage());
}
},
        new Action0() {
@Override
publicvoid call() {
System.out.println("Sequence complete");
}
}
);

运行结果如下：

    0 
    1 
    2 
    3 
    4 
    5 
    Sequence complete

just

just操作符也是把其他类型的对象和数据类型转化成Observable，它和from操作符很像，只是方法的参数有所差别

调用例子如下：

Observable.just(1, 2, 3)
.subscribe(new Subscriber<Integer>() {
@Overridepublicvoid onNext(Integer item) {
System.out.println("Next: " + item);
}

@Overridepublicvoid onError(Throwable error) {
System.err.println("Error: " + error.getMessage());
}

@Overridepublicvoid onCompleted() {
System.out.println("Sequence complete.");
}
});

运行结果如下：

    Next: 1 
    Next: 2 
    Next: 3 
    Sequence complete.

defer

defer操作符是直到有订阅者订阅时，才通过Observable的工厂方法创建Observable并执行，defer操作符能够保证Observable的状态是最新的

下面通过比较defer操作符和just操作符的运行结果作比较

Integer i = 10;

@SuppressWarnings("unchecked")
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

Observable justObservable = Observable.just(i);
i = 12;
Observable deferObservable = Observable
.defer(new Func0<Observable<Integer>>() {
@Override
public Observable<Integer> call() {
return Observable.just(i);
}
            });
i = 15;

justObservable.subscribe(new Subscriber() {
@Override
public void onCompleted() {

        }

@Override
public void onError(Throwable e) {

        }

@Override
public void onNext(Object o) {
System.out.println("just result:" + o.toString());
}
    });

deferObservable.subscribe(new Subscriber() {
@Override
public void onCompleted() {

        }

@Override
public void onError(Throwable e) {

        }

@Override
public void onNext(Object o) {
System.out.println("defer result:" + o.toString());
}
    });
}

运行结果如下：

    just result:10 
    defer result:15

可以看到，just操作符是在创建Observable就进行了赋值操作，而defer是在订阅者订阅时才创建Observable，此时才进行真正的赋值操作

注意：不能用int

timer

timer操作符是创建一串连续的数字，产生这些数字的时间间隔是一定的；这里有两种情况：

一种是隔一段时间产生一个数字，然后就结束，可以理解为延迟产生数字

一种是每隔一段时间就产生一个数字，没有结束符，也就是是可以产生无限个连续的数字

timer操作符默认情况下是运行在一个新线程上的，当然你可以通过传入参数来修改其运行的线程。

下面是调用例子：

Subscription observable = null;

@SuppressWarnings({ "unchecked", "deprecation" })
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
observable = Observable.timer(2, 2, TimeUnit.SECONDS)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Long>() {

@Override
public void onCompleted() {
// TODO Auto-generated method stub

}

@Override
public void onError(Throwable arg0) {
// TODO Auto-generated method stub

}

@Override
public void onNext(Long arg0) {
// TODO Auto-generated method stub
System.out.println("Next:" + arg0.toString());

}
            });
}

@Override
protected void onPause() {
// TODO Auto-generated method stub
super.onPause();
    if (observable != null) {
observable.unsubscribe();
}
}

运行结果如下：

    Next:0 
    Next:1 
    Next:2 
    Next:3 
    ……

注意：Observable.subscribe()方法可以返回一个Subscription的对象,即我们每次订阅都会返回，可以通过该对象，取消订阅。

interval

interval操作符是每隔一段时间就产生一个数字，这些数字从0开始，一次递增1直至无穷大；interval操作符的实现效果跟上面的timer操作符的第二种情形一样。

Subscription observable = null;

@SuppressWarnings({ "unchecked", "deprecation" })
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
observable = Observable.interval(2, TimeUnit.SECONDS)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Long>() {

@Override
public void onCompleted() {
// TODO Auto-generated method stub

}

@Override
public void onError(Throwable arg0) {
// TODO Auto-generated method stub

}

@Override
public void onNext(Long arg0) {
// TODO Auto-generated method stub
System.out.println("Next:" + arg0.toString());

}
            });
}

@Override
protected void onPause() {
// TODO Auto-generated method stub
super.onPause();
    if (observable != null) {
observable.unsubscribe();
}
}

运行结果：

这里写图片描述

若不调用取消订阅，则会一直增加。

range

range操作符是创建一组在从n开始，个数为m的连续数字，比如range(3,10)，就是创建3、4、5…12的一组数字

调用例子如下：

Subscription observable = null;

@SuppressWarnings({ "unchecked", "deprecation" })
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
observable = Observable.range(0, 10).subscribe(new Subscriber<Integer>() {

@Override
public void onCompleted() {
// TODO Auto-generated method stub
System.out.println("Sequence complete.");
}

@Override
public void onError(Throwable arg0) {
// TODO Auto-generated method stub

}

@Override
public void onNext(Integer arg0) {
// TODO Auto-generated method stub
System.out.println(""+arg0);

}
    });



}

运行结果：

这里写图片描述

repeat/repeatWhen

repeat操作符是对某一个Observable，重复产生多次结果

repeatWhen操作符是对某一个Observable，有条件地重新订阅从而产生多次结果

repeat和repeatWhen操作符默认情况下是运行在一个新线程上的，当然你可以通过传入参数来修改其运行的线程。

repeat调用例子如下：

//连续产生两组（1,2,3）的数字
Subscription observable = null;

@SuppressWarnings({ "unchecked", "deprecation" })
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
observable = Observable.range(1, 3).repeat(2).subscribe(new Subscriber<Integer>() {

@Override
public void onCompleted() {
// TODO Auto-generated method stub
System.out.println("onCompleted");
}

@Override
public void onError(Throwable arg0) {
// TODO Auto-generated method stub

}

@Override
public void onNext(Integer arg0) {
// TODO Auto-generated method stub
System.out.println(""+arg0);

}});
}

运行结果如下：

这里写图片描述

说点什么吧

不得不说，Rx的操作符真的是太强大了，当然，也太庞大了，所以，每个都记住也是不可能的，至少我不行。

所以，我都是记录和学习一些常用的，很多用不到的暂时也不记录了，有需要再Google一波，或者直接去这里看
（英文原版）
http://reactivex.io/documentation/operators.html#alphabetical

额，英文不好的，也不慌，看这个，毕竟大多程序员英文....（并不包括我）
https://mcxiaoke.gitbooks.io/rxdocs/content/index.html

这些都详细的一批了。

这个RxJava的系列，最后一个文也是关于Rx操作符的，我也把这些操作符都写在了一个Demo（操作符大全）上，有兴趣的（额，当然，都是烂大街的了。。。）我就不说了吧。

https://github.com/GitHuborz/RxJavaOPDemo

更多操作符，请看下回分解吧~

这里写图片描述

网友评论

本文标题：RxJava 常用操作符大全（一）

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

延伸阅读

深度阅读

您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

RxJava 常用操作符大全（一）

create

from

just

defer

timer

interval

range

repeat/repeatWhen

说点什么吧

相关文章

RxJava