rx-java

0熱

2答えて

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

2熱

1答えて

Observable.just対RxJavaのシングル

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

0熱

1答えて

Kotlin：Thread.sleepを使用するテストをRxJavaに変換する方法TestScheduler

私はRxバッファに何かをキャッシュし、ある程度の間隔（10秒）後にこのテスト対象のバッファに値を挿入するかどうかを調べますルームデータベース。 Thread.sleep（syncTimeInterval）を使用すると、テストは正しく行われます。私はこの同じテストをTestSchedulerを使用して記述したいと思います。ここで、それはのThread.sleep版（試験に合格する）である： @Te

0熱

1答えて

RXJava論理マップチェーン

私は以下のコードをRXJavaで書いています。 validateProduct(payload) .map.(r -> { if(r.getBoolean("valid")){ return createProduct(productPayload); }else{ return null; // request.end() | end the cha

0熱

1答えて

AsyncTaskからRxJavaへの改造要求サイクル

AsyncTask（doInBackgroundメソッド）から次のコードをRxJavaに変更するにはどうすればよいですか？ private String getNextUrl(Call<MessageRs> response, MessageRq rq) throws Exception { Response<MessageRs> rs = response.execute();

0熱

1答えて

リアルタイムデータを使用したリサイクルビューの更新

私はリアルタイムで（毎秒1回）更新しているオブジェクトのリストを持っています。 MVVMアーキテクチャとAndroid DataBindingライブラリを使用するように私のアプリケーションを設計しました私はビューモデルをビューにバインドしました。アクティビティをリロードするたびにすべてが正常に更新されますが、ビューモデルにそのモデルデータが更新され、リアルタイムでビューが更新されますか？私はB

2熱

1答えて

リアクティブストリームを使用するリアクティブプルベースのバックプレッシャー

これは私の理解です。パブリッシャーとサブスクライバーがあります。パブリッシャとサブスクライバのための擬似コードは何かなど、 Publisher{ Subscriber s; subscribe(Subscriber s){ this.s = s; s.onSubscribe(new Subscription(){ onRequest(i

0熱

1答えて

RxJava：範囲演算子が動作していません

実際には、1秒周期で値を出力するストリーム/ Observableを作成しました.1秒間隔で値を出力しますが、6を発光した後に終了/停止しません。 Observable myObservable = Observable.range(1, 6) .interval(5000, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedu

0熱

1答えて

RxJava：メインスレッドとは別のスレッドで観測可能にする方法

観測可能なコードをメインスレッドとは別のスレッドで実行したい。私はこれを行うことができますどのように、私はこのようにやっている： Observable operationObservable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(Observable