官术网_书友最值得收藏!

Observable.future()

RxJava Observables are much more robust and expressive than Futures, but if you have existing libraries that yield Futures, you can easily turn them into Observables via Observable.future():

    import io.reactivex.Observable;
import java.util.concurrent.Future;

public class Launcher {
public static void main(String[] args) {

Future<String> futureValue = ...;

Observable.fromFuture(futureValue)
.map(String::length)
.subscribe(System.out::println);
}
}
主站蜘蛛池模板: 信阳市| 兴化市| 登封市| 枣阳市| 绵阳市| 揭西县| 基隆市| 天峻县| 福贡县| 兴仁县| 板桥市| 伊宁市| 石棉县| 六枝特区| 响水县| 上蔡县| 怀化市| 滕州市| 罗源县| 无为县| 科技| 鄂托克前旗| 天门市| 凤山市| 聂拉木县| 博兴县| 石嘴山市| 伊金霍洛旗| 祁门县| 百色市| 和平县| 景谷| 珲春市| 怀柔区| 黄大仙区| 富裕县| 兴化市| 荣昌县| 合阳县| 湘潭县| 邹城市|