rx-android

    0

    2答えて

    に基づいRetrofit2.0のAPIコール シナリオ:(2.0.0版)RxJava2と、(3.9.0版)OkHTTP3を残りのAPI呼び出しの200 OK HTTPを返し Observable<ServerResponse> backendService.isUserVerified("someuserName") 期待成功レスポンスJSON POJOユーザーが検証された場合 ユーザーは、次

    1

    1答えて

    新しいスレッドでRxJava監視オブジェクトを実行する際に問題が発生しています。 Scheduler.io()でジップDBクエリを実行しようとしていますが、UIスレッドは関係なくブロックします。理由は分かりません。 DB用 コード: public Observable<List<T>> searchModelsInView(View view, final Collection<String> s

    -1

    2答えて

    現在の場所の取得を実装しようとしています。私はこれら両方のコードを使用しました。 mFusedLocationClient = LocationServices.getFusedLocationProviderClient(this); mFusedLocationClient.getLastLocation()... 位置精度は、位置acccuracyは100〜200メートル2000メー

    0

    1答えて

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

    0

    2答えて

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

    0

    1答えて

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

    -1

    2答えて

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

    0

    2答えて

    publishSubject.onNext(someValue)を複数回呼び出すと、debounceのように1つの値しか必要としませんが、最後の値を渡すので、すべてスキップする必要があります私がonNext()を1秒間呼び出すのを止めるまで、束の中の最初のものを除いて値。 私はthrottleFirst(1000,TimeUnit.MILLISECONDS)のようなものを使用しようとしましたが、デ

    2

    1答えて

    私はRxJavaとRxAndroidを初めて使い、Observable.justとSingleの違いを理解しようとしています。それはそれぞれがオブザーバーのために1つのアイテムを放出するように設計されているように見えます。 ここに2つのボタンを備えた私の簡単なAndroidのアクティビティのコードを示します。最初のボタンはObservableを作成し、第二ボタンがSingleを作成します。 fin