rx-java2

4熱

4答えて

DOCは概念的を言い、それは0または1項目またはいくつかの反応源によってシグナリングエラーが存在する可能性放射パターンを捕捉する手段を提供するシングルおよびCompletableの和集合です。しかし、私はそれが本当に何を意味するかはわかりません。それはjava8のOptionalのようです。次の2つのコードは同じ結果ですが、Maybeは何ができるのか分かりません。Optionalはできま

1熱

2答えて

各加入者は、Flowableから異なる値を取得できますか？

一部の加入者が流動性のあるものを1つ購読し、この流動性のあるアイテムを加入者に送信すると、各加入者は異なる値を得ることができますか？例えば、流動性が発する場合 0、1、2、3 ... あるオブザーバー2,0取得し、他の観察者は次のように、ように1、3、取得しロードバランサ。

0熱

1答えて

RxJava 2.0でReactive-Streamsプロセッサを使用

RxJava 2.0で使用したいorg.reactivestreams.Processorがあります。しかし、org.reactivestreams.Publisherをio.reactivex.Flowable#fromPublisherのようにRxJavaに統合するための変換はありますが、org.reactivestreams.Processor（またはorg.reactivestreams.

0熱

1答えて

repeatUtil（）私は、次のコードを使用するとRxjava 2.xの

では動作しません：（Observable.createを（）） Observable.create(new ObservableOnSubscribe<User>() { @Override public void subscribe(ObservableEmitter<User> emitter) throws Exception { emitter.onN