RxJava操作符大全

RxJava操作符大全 创建操作 以下操作符用于创建Observable。 create： 使用OnSubscribe从头创建一个Observable，这种方法比较简单。需要注意的是，使用该方法创建时，建议在OnSubscribe#call方法中检查订阅状态，以便及时停止发射数据或者运算。 Observable.create(new Observable.OnSubscribe<String>()

>>阅读原文<<