rx-java

    0

    1答えて

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

    2

    1答えて

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

    0

    1答えて

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

    0

    2答えて

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

    0

    3答えて

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

    0

    1答えて

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

    0

    1答えて

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

    -1

    2答えて

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

    0

    1答えて

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