rx-java

0熱

1答えて

サブスクリプションに対してonErrorが呼び出された場合、オブザーバを再起動するにはどうすればよいですか？

私は現在使用しています： PublishSubject<PubNubObserverData> = PublishSubject.create() は私が onError(Throwable e) がで呼び出されたときに、私は、サブスクリプションを再起動することができますどのように不思議でしたか？現在、エラーが発生するとサブスクリプションは停止します。

6熱

1答えて

RxJava Completabe andThenテスト

I持って、次のRxJava2 Kotlinコード： val tester = Completable.complete() .andThen(SingleSource<Int> { Single.just(42) }) .test() tester.assertComplete() tester.assertValue(42) これは、上のget操作シングル

0熱

1答えて

RxJava：ホット観測の消費者

私はRxJavaの複雑さとグリップを取得しようとしますが、初心者の問題をヒットしています：私は寒い1から熱いに観察を作成しようと、これは2人の消費者をサブスクライブしていますプッシュされたイベントを異なる速度で処理します。ここでは、コードスニペットです： ConnectableObservable<Long> ob = Observable.interval(200, TimeUnit.MILL

0熱

2答えて

RxJava 2 - スケジューラでスローされた致命的な例外

AsynchタスクをJavaRx 2に変換しようとしています。私はGoogleシートAPIを使用してスプレッドシートからデータをダウンロードします。私はIOスレッドとobserveOnに加入し、観察可能なを作成するので、 private String getLeagueData(String urlString) throws IOException { //Download JSON file

0熱

1答えて

OnErrorReturnは考えてみましょう。この例をflatMap

の内側に発生する終了を飲み込むしない： @Test public void testOnErrorReturn() { final Observable<String> stringObservable = Observable.defer(new Callable<ObservableSource<String>>() { @Override publ

0熱

1答えて

共有オペレータはRxJavaで何をしますか？それはいつ使うべきですか？

私はshare（）がpublish（）。refCount（）の代わりであることを知っています。はその後RxJavaのwikiから： Observable.publish（） - 接続可能な観察可能 ConnectableObservable.refCount（）として観測可能表し - 普通の観察可能このメイクのように接続可能な観察可能な振る舞いをします私は混乱しています。 publish（）。

0熱

1答えて

Rx Javaマップ関数を並列に実行する

RxJavaとリアクティブプログラミングが新しくなりました。私は2つの関数を1つのObservableパイプラインの一部として並列にマップしようとしていますが、このようには動作しません。ここに私のコードです。 Observable.fromCallable(thatReturnsNumberOne()) .observeOn(newThread()) .map(d

1熱

1答えて

RxJavaのマージ（）でアクティブなストリームの数を制限する方法は？

私は、複数のイベントストリームをmerge（）演算子と組み合わせ、限られた量の 'アクティブストリーム'を探しています。たとえば、6つのストリームをマージすると（すべてが別のスレッドで動作しています）、merge（）はそれらのすべてにサブスクライブしますが、最初は3に、サブスクリプションを完了する6つのストリームのすべてが完了するまで繰り返す。マージや他のRxJava演算子でこれを達成することは可

1熱

1答えて

RxJava：一時ステートフル変数大きいRxJavaアプリケーションで

ことなく選択されたソース観測を中断するためのパターンは、私はホット、無限ソース観測の数を有しています。これらからの排出は統合され、下流のオブザーバーによって処理されます。この処理の結果は、非監視中のObservableが引き続き放出すると予想され、オブザーバがNon-Suspended Emissionを消費すると予想される一方で、Source Observableの一部からの放出を一時的に中断す