rx-java

0熱

1答えて

メインスレッドで実行されていないクエリからカウントを取得するのに非常に奇妙な問題が発生しています。私はRecyclerViewのRealm用アダプターを使用するUIを持っています。私はそれはそれは前回のカウントが最後のトランザクションの前にいた返されます何らかの理由で、出発点を設定することができるように、クエリの前にレコード数をカウントする方法を持っています。 D/SearchControlle

1熱

1答えて

なぜonSubscribeがrxjavaで動作しないのですか？

observeOn行を書き込まないとコードの下を実行すると、getView().showBlockLayout(isBlock);がレイアウトを非表示または表示しようとするため、アプリケーションがクラッシュします。ですが、observeOn(AndroidSchedulers.mainThread())以下をsubscribeOn(AndroidSchedulers.mainThread())に

0熱

1答えて

RxJavaで観測可能なものを別の観測可能なものにする方法は？

私はさらに私が終わった方法は以下の通りです、私のAPIが観察返したようネットワーク等をチェックし、表示/非ローダーを表示することができます別の方法で改造API呼び出しをラップしたい： private <T> Observable<T> request(final Observable<T> apiCall, final ViewManager viewManager) { return

0熱

1答えて

RxJavaを使用して各リストアイテムを非同期操作結果とマージするにはどうすればよいですか？

私はList<News>を持っています - 私のニュースのリスト。私は、（APIから）ニュース画像リストを取得するための各ニュースの非同期要求を行わなければならない。（私はそのObservable.fromIterable(newsList)のための使用を考えると、その後zipWith(imagesListRequestObservalbe, News, News(with images))を

0熱

1答えて

RxJavaシーケンスに要素が含まれていないエラー

私はRxJavaを使用しています。これらのエラーが発生する場合を除いて、すべてがうまく見えます。 Caused by: java.util.NoSuchElementException: Sequence contains no elements at rx.internal.operators.OperatorSingle$ParentSubscriber.onCompleted(Operat

4熱

1答えて

RxJava2観測可能な背圧

最近、私は背圧がどのように働くのか分かりません。私は小さなテストをしたと私はそれがMissingBackpressureException例外で失敗する必要があることを期待：それはMissingBackpressureExceptionを生成しないのはなぜ Emit: 0 Emit: 1 Emit: 2 ... Emit: 10000 Processed:0 Processed:1

0熱

2答えて

AsyncTaskをRxJavaに変換する

Rxの新機能ですので、次のAsyncTaskをRxに変換するための助けを捜していますので、Rxをもう少し詳しく知ることができます。私はいくつかの他のSOの答えを見つけましたが、それは多少関連していましたが、それらの多くはネットワーク要求をしておらず、回答者ごとに異なる演算子を使用していました。相続人AsyncTask：ここでは、（MainActivityからすべてのコードが含まれている）Wha

0熱

1答えて

requery db＆rxjava observableResultは、後続の関数を複数回呼び出します。

on android私はrequery dbを使用しており、DBの変更をサーバーにアップロードしようとしています。同じことを達成するために、私は次のロジック Scheduler sub2 = Schedulers.newThread(); Scheduler ob2 = Schedulers.newThread(); data.select(Broadcaster.class)

1熱

1答えて

RxJava 2を使用して再試行でレースをオーケストレーションするにはどうすればよいですか？

与えられたファイルを扱うことができる、またはできない、すなわちある特定のパーサーがある確率で成功するか、p > 0か、常に失敗する（p=0）という脆弱な（時には失敗する）パーサーがあるとします。 RxJavaを使用して、この一連のパーサーを受信ファイルのストリームに登録し、ファイルを解析する 'race'にすることは可能ですか？パーサーが最初に失敗する可能性があるが、引き続きファイルを解析できる

0熱

1答えて

要求キューを実装する方法は？

サードパーティSDKのメソッド（非同期メソッドを使用してリモートサーバーにHTTPリクエストを送信する）とRetrofit2 + OkHttp + Rxを使用してこのサーバーに直接アクセスするアプリケーションがあります。 - 1秒、最大で5要求 new SdkRequest("some", "arguments", "here") .setCompleteListener(this::o