RxJava返回函数中的订阅值

Question

出于某种原因,我有时想使用RxOperators而不是普通的java方式转换数据结构,因为它更干净,更清洁.例如:

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

有没有办法等待observable的结果并在函数中返回:这样做(但它不起作用):

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

Answer 1

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

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

更新: 尽管上面的代码完全有效并且可以按预期工作,但这不RxJava应该如何使用.如果您的唯一目标是转换集合,那么有更好的方法:

• Java 8有一个StreamAPI
• Guava有自己的集合API
• Apache有一个commons-collections库