时间戳

首页 > 解决方案 > 如何从 Observable java rx 1.2 和 kotlin 中提取、工作和返回信息

kotlin - 如何从 Observable java rx 1.2 和 kotlin 中提取、工作和返回信息

问题描述

我正在使用观察者链。我正在订阅实习生电话的调用方法，就像：

 Observable.just(dCSService.get(dCSServiceContext))
                .map { "hello " + it }
                .subscribe { println(it)}

在这两种情况下，在地图和订阅中，我都得到了一个 Observable，关于如何从 observable 访问对象的任何想法？这些对象的类型：

Single<List<DCSItem?>>

提前致谢！

标签： kotlinobservablerx-java

解决方案

正如我所了解的那样，如果在地图内你得到一个你使用错误的运算符。你不需要使用 Observable.just 来启动一个流，因为你已经有一个流，所以你可以这样做

 dCSService.get(dCSServiceContext)
            .map { "hello " + it }
            .subscribe { println(it)}

如果您希望列表一一发出，您可以使用

 dCSService.get(dCSServiceContext)
            .flatMapIterable(item -> item)
            .map { "hello " + it }
            .subscribe { println(it)}

推荐阅读