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

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);
}
}
主站蜘蛛池模板: 扶风县| 东丽区| 广水市| 阿克陶县| 莎车县| 资溪县| 南充市| 满城县| 溆浦县| 武威市| 长兴县| 蓬溪县| 突泉县| 阿瓦提县| 兴宁市| 丘北县| 石楼县| 西平县| 邛崃市| 榆中县| 松桃| 安仁县| 城步| 漳平市| 福贡县| 林甸县| 柏乡县| 响水县| 涟水县| 黄梅县| 宿迁市| 涞水县| 清新县| 商都县| 乐都县| 汕头市| 若尔盖县| 余庆县| 吴江市| 碌曲县| 兴安县|