rx-java

0熱

1答えて

RxBindingを使用してEditTextの右側のドロアブルにクリックリスナーを実装する方法はありますか？私が見つけた唯一のものがある： RxTextView.editorActionEvents(mEditText).subscribeWith(new DisposableObserver<TextViewEditorActionEvent>() { @Override

4熱

1答えて

RxJava2 TestObserverクラス - TestSubscriberクラスに似たgetOnNextEventはどこですか？

私は結果を確認できるように、加入者のonNextから返された値を取得する方法を探しています。 TestSubscriberはgetOnNextEventと呼ばれる素晴らしいメソッドを持っていましたが、私がTestObserverを使用すると、このようなメソッドが表示されないので、私はそれをチェックして結果を得ることができます。すべて廃止され、IDEにチェックインしても表示されません。ここでは私が

0熱

1答えて

RXサンプルは「一時停止後最初に」再起動します

誰かがrx javaでこのケースを実装する方法を提案できますか？前に加入した場合でも、第一の発光（）とサンプルスタート：それはsampleのように見えますが、2つの違いがあります。 2 emittions（この例ではと）との間の間隔は、サンプルレート（1秒）を超える場合、サンプルは、後者emittion（）に再起動します。

0熱

1答えて

アンドロイドでオブザーバブルを終了するのを待つ方法は？

私はDataModuleの魔女が開始 public void onCreate() { DataModel.loadData().doOnSuccess(this::bindData) .subscribe() ... 上のデータを必要とするいくつかの方法 static Single<DataModel> loadData(); はまた、活動の魔女があるのD

0熱

1答えて

なぜRxJavaでNull値がonNextになっていますか？（rxjava2 + retrofit2）

これはインターフェイスです： @GET("solicitation/get/{protocol}") Observable<Solicitation> getProtocol(@Path("protocol") String protocol, @Query("X-Authorization") String apiKey); そして、これは私のApiClientクラスであり、 if (re

1熱

1答えて

RxJava2 - 繰り返し作業のインターバル＆条件

上に観察を実行改造で実行これは私のインターフェイスです： @GET("solicitation/all") Observable<SolicitationResponse> getAll(@Query("X-Authorization") String apiKey); 私はそれを実行する場所です： apiService.getAll(getResources().getStrin

0熱

1答えて

RxBus：一般的なイベントを送信する

Eventクラスは私のバスとして機能しているPublishRelayに投稿したいと思っています。私のRxBusポストイベントをジェネリック型にしたいのですが、バス自体は一般的ではありません。私は何を変える必要があるかについて私にアイデアを教えてもらえますか？あなたは、一般的なイベントを使用したい場合は public class Event<T> { protected String n

1熱

1答えて

Springからバックグラウンドで観測可能なRxJavaを購読する

Webアプリケーションのバックグラウンドで処理したいRxJava Observableがあります。これは、サービスがメッセージキューのイベントに反応できるようにするためです。このObservableを直接購読することができるSpringの設定はありますか？ Spring TaskExectorのようなものは、バックグラウンドスレッドがObservableイベントを処理できるようにします。しかし、私

0熱

1答えて

RxJava：1つのリクエスト - >整数のリスト - >各int - >結果に対するリストのリスト

私はRxJavaの初心者です。Observableの構築中にいくつかの困難があります。私のタスクは次のとおりです。サーバーの応答でサーバーgetExpPointsIdArrayByHouse へクエリ。 int値ごとに、サーバーへの別のクエリを実行する必要があります。 Observable .defer(new Func0() { @Override p

2熱

1答えて

RxJavaはisUnsubscribedに相当します

私は、Reactive Programming with RxJavaのバージョン2ではなく、バージョン1を対象とした例を使って作業しています。無限ストリームの紹介には、次の例があります。並行性）： Observable<BigInteger> naturalNumbers = Observable.create(subscriber -> { Runnabler =() -> {