出于某种原因,我有时想使用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
库
原文地址:https://www.jb51.cc/java/121013.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。