operators - RxJava 在函数中返回订阅值

Question

出于某种原因，我有时想使用 RxOperators 而不是普通的 java 方式来转换数据结构，因为它越来越干净。例如:

Observable.from(listOfStrings)
.filter(string -> string.getNumber() >5)
.toList()

是否有任何方法可以等待可观察结果并在函数中返回:这可以(但不起作用):

private String getFilteredString(String string){
   Observable.from(listOfStrings)
       .filter(string -> string.getNumber() >5)
       .toList()
       .subscribe(finalStirng -> {
       return finalString;
       })
}

Answer 1

您可以使用.toBlocking()将任何Observable转换为同步的:

private List<String> getFilteredString(List<String> strings) {
  return Observable.from(strings)
      .filter(string -> string.length() > 5)
      .toList()
      .toBlocking()
      .single();
}

更新:尽管上面的代码完全有效并且可以按预期工作，但这不是 RxJava 的使用方式。如果您的唯一目标是改造集合，则有更好的方法可以实现:

• Java 8 有 Stream API
• Guava有自己的collections API
• Apache 有 commons-collections图书馆