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

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);
}
}
主站蜘蛛池模板: 宜阳县| 峡江县| 遂宁市| 新昌县| 侯马市| 隆德县| 建水县| 洛南县| 安阳市| 柏乡县| 庆元县| 彰武县| 行唐县| 玛纳斯县| 梅河口市| 古浪县| 全南县| 汉寿县| 彭水| 资中县| 扶绥县| 文山县| 石渠县| 贞丰县| 南丰县| 吉林省| 老河口市| 江口县| 铜陵市| 蒙山县| 武汉市| 南雄市| 凤冈县| 益阳市| 福州市| 通化市| 慈溪市| 沭阳县| 金乡县| 湖南省| 宜城市|