出于某种原因,我有时想使用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;
})
}
解决方法
您可以使用.toBlocking()将任何Observable转换为同步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库
