RxJava firstElement 与 lastElement 以及 elementAt

1 firstElement 

文档如下

2 lastElement  

文档如下

3 elementAt

文档如下

下面写一个下代码

firstElement 

Observable.just(1,2,3,4,5,6).firstElement().subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

 打印结果为1 

lastElement 

 Observable.just(1,2,3,4,5,6).lastElement().subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

打印结果为 6

elementAt

 Observable.just(1,2,3,4,5,6).elementAt(2).subscribe(new Consumer<Integer>() {@Overridepublic void accept(Integer integer) throws Throwable {Log.e("--------rxjava",integer.toString());}});

打印结果为3 

总结

以上是生活随笔为你收集整理的RxJava firstElement 与 lastElement 以及 elementAt的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。