rx-java2

2熱

1答えて

just()演算子で2つの引数を渡しています。私のコードのスニペットは： Observable<Integer> observable = Observable.just(1,2); observable.subscribeOn(Schedulers.newThread()) .subscribe( new Observer<Integer>() {

0熱

2答えて

RxJava - yのxを持つカウンタ

どうすればいいですか？私は次のように思いついた、それは私はyのxのxを計算することができますが、私は同様にyを計算するために改善することができますか？ Observable<LoadedPhoneContact> phoneContacts = getPhoneContacts() .flatMapObservable(contacts -> Observable.fromIterab

0熱

1答えて

rxJava2 CompositeDisposable in presenter

私は自分のアプリをrxJava2に移行していますが、いくつかのことを明確にしたいと思います。私BasePresenterクラスで私は、次の手順を実行します @Override public void attachView(T mvpView) { this.mvpView = mvpView; compositeDisposable = new CompositeDispo

1熱

3答えて

ネットワークに接続していないときにクライアントをクラッシュさせるのはなぜですか？

私のAndroidアプリケーションでは、ネットワークコールのためにRetrofit 2.2とRxJava 2を使用します。デバイスがネットワークに接続されている場合はすべて正常です。モバイルとWi-Fiネットワークを無効にすると、アプリがクラッシュします。奇妙なことに私はエラーを正しく処理できますが、アプリはとにかくクラッシュします。これは改修のためのAPIインタフェースは、次のとおりです。

2熱

1答えて

RxJavaの "シリアライズ"メソッドの使用例

私はobservableを "シリアライズ"する必要があるケースを知りたい。私は、 "onNext"メソッドが次々に呼び出される代わりに同時に呼び出される場合を意味します。

5熱

1答えて

RxJava2補完可能なandThenオペレータで呼び出されるシーケンスの順序

RxJava1からRxJava2に移行しようとしています。私は前にObservable<Void>を持っていたすべてのコード部分をCompleatableに置き換えています。しかし、私はストリームコールの順序で1つの問題に遭遇しました。以前Observablesを扱っていて、マップとフラット・マップを使用していたとき、コードは「期待どおり」に機能しました。しかし、andthen()オペレータは少し

4熱

3答えて

独立したデカルト積のinRxJava

今私はObservable<Observable<Integer>を保持していますが、どのようにしてそれをn-aryデカルト積を含むObservable<int[]>に転送できますか？例えば：非同期の方法で、デカルト積を作成 Observable<Observable<Integer> ob = Observable.just( Observable.just(0,1), Ob

0熱

2答えて

RxJavaを使用した一定期間のネットワークコールのキャッシュ

Retorfit + RxJava2を使用してネットワークを作成していて、30秒間応答をキャッシュします。 30秒後に呼び出されたコールは、サーバーから最新の結果を取得する必要があります。私はReplayオペレータを使ってこれを試みましたが、私が購読を呼び出すたびにネットワークコールを作ります。私はRxJavaの専門家ではないので、そのようなキャッシングにReplayを使用することについての私の理

0熱

1答えて

RxBinding2チェーンは、呼び出し - SearchViewQueryText

を、私は以下のように見える私のViewでRxBinding2あります return discogsService.getSearchResults(searchTerm, mContext.getString(R.string.token)) .subscribeOn(Schedulers.io()) .flatMapIterable(RootSearchRespo

4熱

1答えて

Rx Java 2：コールバックを折り返す方法は？

私はRx Java 1でコールバックをラップするためにこのコードを持っていますが、それはうまくコンパイルされますが、RX Java 2に切り替えるとコンパイルされません。 return Observable.fromEmitter(new Action1<AsyncEmitter<Integer>>() { @Override public void call(Asyn