Tag: observable

如何将Observable对象映射为Flowable <？>？

private Observable< SimpleResource > resource; return resource.map(new Function<SimpleResource, Flowable<Data>>() { @Override public Flowable< Data > apply(SimpleResource resource) throws Exception { return resource.data().toFlowable(); } }); Single<Data> data(); 我需要Flowable，但是我的结果是Observable>

Kotlin Android中的Observable无法从（）运算符调用

我正在尝试使用kotlin来学习RxJava2，我正在关注这个很好的在线教程。 首先，我添加了这两行gradle.build文件： compile 'io.reactivex.rxjava2:rxandroid:2.0.1' compile 'io.reactivex.rxjava2:rxjava:2.1.3' 我试图用这个代码实现Observable模式： import io.reactivex.Observable class MainActivity : AppCompatActivity() { override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) setContentView(R.layout.activity_main) val observable = Observable.from(arrayOf(1, 2, 3, 4, 5, 6)) } } 这应该很容易，但我不能从Observable（Unresolved reference：from）的（）运算符调用。 所以基本上我在开始之前就卡住了。 有没有人知道我做错了什么？