rx-java

0熱

2答えて

私は自分のアプリケーションで検索するシステムをやっています。 public class UpdateSearchResults { public UpdateSearchResults(String text) { this.text = text; } public String getText() { return

2熱

1答えて

RxJava - 「一つだけ発光を一度に観測可能なチェーンを走行させている...」

私はここにブログの記事を読んでいる：http://tomstechnicalblog.blogspot.com/2016/02/rxjava-understanding-observeon-and.html それはそのありませんと言われてどのスケジューラを購読しているのかによって、一度にObservableチェーンの上を移動できるのは1回だけです（）。以下は、次の発光を開始する前に、放射源

1熱

1答えて

RxJava2 FlowableがサブスクライバのonNextメソッドを呼び出さない

私はrxjavaで新しく、私はFlowableに問題があります。 onCompleteメソッドがflatMapで呼び出された場合、onNextメソッドが呼び出されませんでした。ここに何が問題なの？何か提案がありますか？ ResourceSubscriberのJavadocのから ResourceSubscriber<List<Song>> subscriber = new ResourceSub

0熱

1答えて

RxJavaは彼らに

を完了せずに2つの観測ジップ私は2つの観測があります。そして、デバイスに接続し、それが加入者を有し、一方の接続を維持します Observable<RxBleConnection> bluetoothObservable = RxBleClient.create(getBaseContext()).getBleDevice(macAddress) .establishConnection(fals

2熱

2答えて

ObservableにサブスクライブするBehaviorSubjectを作成するにはどうすればよいですか？

私はBehaviorSubjectを返さなければならない関数を持っています。対象は、の最新バージョンを返すように意図されてProfile （ユーザー）Profileは3人のメンバーへの参照が含まちょうどPOJOです： - Userを、 - そのユーザーのMeasurementList、 - とDeadline。これらのプロパティのうちの2つは、改造呼び出しによって取得され、そのうちの1つはすでに

1熱

2答えて

ユニットテスト：AndroidでRxJavaでObservableを確認する方法

Retrofit 2、Mockito 1.10、RXJava 1.0を使用しているAndroidアプリケーション用の単体テストを作成しようとしています。私はラムダをサポートするJavaバージョンを使用していません！私のコードでは、観測を使用して、私は次の操作を行うことができます when(myAPI.Complete(anyString(), any(MyContainer.class)))

0熱

1答えて

は、AndroidのユニットテストでdoNothing.when句の

をMockito UnfinishedStubbingExceptionを受信すると、まず、私はそれが呼び出されたときに、設定されます、方法を持っている私のセットアップはRXJava 1、レトロフィット2であり、私は、Java 7にを使用していますアトミックブール値をtrueにします。この方法では、改造APIが呼び出されます。完了時に、timeoutなど...アトミックブール値がfalseに

0熱

1答えて

RXレトロフィット-2を搭載したレギュラーVS通常のレトロフィット-2

私は現在、APIの解析にRetrofit2を使用しています。私の新しいアプリケーションではRxJava + Retrofitと変更するように求められました。どうすればこれを実現できますか？とRetrofitを一緒に使用するメリットは何ですか？ご協力いただければ幸いです。以下は私は私の新しいアプリケーションのためにRxJava +レトロフィットでそれを変更するように頼まれたとおり、私は Ret

0熱

1答えて

RxJavaのチェック例外の処理

私はRxJava1を理解し始めています（今はRxJava2にならないようにしましょう）。私は以下のようなコードをしました： MoviesAPI.findMovieURLsByType("comedy") .map(s -> { try { return potentialCheckedException(s); //Throws CheckedExcept