一、描述
只发射第一项(或者满足某个条件的第一项)数据。
如果你只对Observable发射的第一项数据,或者满足某个条件的第一项数据感兴趣,你可以使用First操作符。
在某些实现中,First没有实现为一个返回Observable的过滤操作符,而是实现为一个在当时就发射原始Observable指定数据项的阻塞函数。在这些实现中,如果你想要的是一个过滤操作符,最好使用Take(1)或者ElementAt(0)。
在一些实现中还有一个Single操作符。它的行为与First类似,但为了确保只发射单个值,它会等待原始Observable终止(否则,不是发射那个值,而是以一个错误通知终止)。你可以使用它从原始Observable获取第一项数据,而且也确保只发射一项数据。
在RxJava中,这个操作符被实现为first,firstOrDefault和takeFirst。
可能容易混淆,BlockingObservable也有名叫first和firstOrDefault的操作符,它们会阻塞并返回值,不是立即返回一个Observable。
还有几个其它的操作符执行类似的功能。
只发射第一个数据,使用没有参数的first操作符。
二、示意图
三、示例代码
1 | Observable.just(1, 2, 3, 4, 5, 6) |
四、运行结果
1 | onNext: 1 |
项目代码已上传到Github:https://github.com/SherlockShi/RxJavaBestPractise
五、更多
first操作符还有以下变体:
- first(Func1)
跟first相关的操作符还有:
- firstOrDefault(T)
- firstOrDefault(T, Func1)
- takeFirst(Func1)
- single()
- single(Func1)
- singleOrDefault(T)
- singleOrDefault(Func1,T)
详情可查阅下面的参考资料。
六、参考资料
PS:欢迎关注 SherlockShi 个人博客