rx-java

0熱

1答えて

新しいスレッドを生成することによって、ネットワーキングの仕事をするレガシーなRXコードがあります。作業が終了すると、コールバックで1つのメソッドが呼び出されます。私はこのコードが実行されているスレッドを制御できません。それは遺産であり、それは新しいThreadを単独で生み出します。これは次のように単純化することができます。 interface Callback { void onS

2熱

1答えて

このRxJavaコードをリファクタリングする方法はありますか？

私は次のようになり、私の観察可能なサブスクリプションがあります。 compositeDisposables.add(githubService.getRepos() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(

0熱

1答えて

Rx：観測にN秒以上かかることがあります。

私のアプリのスプラッシュ画面を作っています。私はメイン画面に行く前に少なくともN秒間それを続けたい。私はRx変数myObservableを持っています。これはサーバーまたはローカルキャッシュからデータを返します。 myObservableをで少なくともN秒で完了させるにはどうすればよいですか？ Observable.forkJoin(myObservable, Observable.timer(

0熱

2答えて

RxJavaシングル/私は興味深い問題で</p> <p>に直面しているインタフェース

の観察可能なリターンの実装は、インタフェースとConcreteResultsが実装されています。しかし、私はこの問題を解決するためにどのようにエラーに Error:(149, 27) error: incompatible types: Single<ConcreteResults> cannot be converted to Single<IResults> を取得していますか？私は抽象

0熱

3答えて

http投稿応答がnullです

私はHTTPリクエストをREST APIに送信していますが、サーバーから状態確認応答を受け取っていますが、このスクリプトでは常に 'myError'機能が実行されます。バックエンドでは、すべてのエラーなしですべてが正常に実行されています。エラー関数でも、応答値は未定義のままです。 var toDoApp = angular.module('toDoApp'); toDoApp.factory(

0熱

1答えて

RxAndroid - Zip演算子でエラーを処理する

私は、要求を並行して実行する方法を見つけようとしており、観測可能なものがすべて終了すると処理しています。すべてのオブザーバブルが応答を返すにもかかわらず、すべてが機能しているにもかかわらず、すべてが完了したときにすべてのエラーを処理する方法はありません。これは基本的に平行に2つのリクエストを実行ジップオペレータのサンプルである：このアプローチに Observable.zip( ge

0熱

1答えて

RxJavaで一般的なObservableのTestScheduler

私はTestSchedulerを使い始めました。私は、この代わりに使用する場合 @Test public void test1() throws Exception { //when TestScheduler scheduler = new TestScheduler(); TestObserver<Long> subscriber = new TestObser

-1熱

2答えて

RxJava Single.createがスレッドを指定できません

initialize（）メソッドはうまくいっていましたが、他の呼び出しと同じioスレッド（ioScheduler）で動作する必要があります。 internal fun initialize(): Single<Boolean> { return Single.create<Any> { singleEmitter -> singleEmitter.onSuccess(true

0熱

1答えて

Asynctask status && RxJava2で同等のキャンセルが可能ですか？

私はRxJava2を学び、AsyncTasksをObservablesに変換しようとしています。変換しようとしている次のコードがあります。 if(asyncTask.getStatus() == AsyncTask.Status.RUNNING){ asyncTask.cancel(); } asyncTask = new CustomTask(); asyncTask.exec