First

只发射第一项(或者满足某个条件的第一项)数据

first

如果你只对Observable发射的第一项数据,或者满足某个条件的第一项数据感兴趣,你可以使用First操作符。

在某些实现中,First没有实现为一个返回Observable的过滤操作符,而是实现为一个在当时就发射原始Observable指定数据项的阻塞函数。在这些实现中,如果你想要的是一个过滤操作符,最好使用Take(1)或者ElementAt(0)

在一些实现中还有一个Single操作符。它的行为与First类似,但为了确保只发射单个值,它会等待原始Observable终止(否则,不是发射那个值,而是以一个错误通知终止)。你可以使用它从原始Observable获取第一项数据,而且也确保只发射一项数据。

在RxJava中,这个操作符被实现为firstfirstOrDefaulttakeFirst

可能容易混淆,BlockingObservable也有名叫firstfirstOrDefault的操作符,它们会阻塞并返回值,不是立即返回一个Observable。

还有几个其它的操作符执行类似的功能。

过滤操作符

first

只发射第一个数据,使用没有参数的first操作符。

示例代码

  1. Observable.just(1, 2, 3)
  2. .first()
  3. .subscribe(new Subscriber<Integer>() {
  4. @Override
  5. public void onNext(Integer item) {
  6. System.out.println("Next: " + item);
  7. }
  8. @Override
  9. public void onError(Throwable error) {
  10. System.err.println("Error: " + error.getMessage());
  11. }
  12. @Override
  13. public void onCompleted() {
  14. System.out.println("Sequence complete.");
  15. }
  16. });

输出

  1. Next: 1
  2. Sequence complete.

first(Func1)

first

传递一个谓词函数给first,然后发射这个函数判定为true的第一项数据。

firstOrDefault

firstOrDefault

firstOrDefaultfirst类似,但是在Observagle没有发射任何数据时发射一个你在参数中指定的默认值。

firstOrDefault(Func1)

firstOrDefault

传递一个谓词函数给firstOrDefault,然后发射这个函数判定为true的第一项数据,如果没有数据通过了谓词测试就发射一个默认值。

takeFirst

takeFirst

takeFirstfirst类似,除了这一点:如果原始Observable没有发射任何满足条件的数据,first会抛出一个NoSuchElementExceptiontakeFist会返回一个空的Observable(不调用onNext()但是会调用onCompleted)。

single

single

single操作符也与first类似,但是如果原始Observable在完成之前不是正好发射一次数据,它会抛出一个NoSuchElementException

single(Func1)

single

single的变体接受一个谓词函数,发射满足条件的单个值,如果不是正好只有一个数据项满足条件,会以错误通知终止。

singleOrDefault

single

firstOrDefault类似,但是如果原始Observable发射超过一个的数据,会以错误通知终止。

singleOrDefault(T,Func1)

single

firstOrDefault(T, Func1)类似,如果没有数据满足条件,返回默认值;如果有多个数据满足条件,以错误通知终止。

first系列的这几个操作符默认不在任何特定的调度器上执行。