rx-java2

1熱

1答えて

完了する前にObservableが正確に1つの値を出さない場合は、カスタムエラーをスローします。は私が例を示してみましょう： Observable<SomeClass> stream = ... stream .filter(...) .singleOrError(new MyCustomException()) は、だから私は工assオブジェクトのストリームを持っています。私はfi

1熱

2答えて

flatMapCompletableが指定されたアクションを呼び出さない

Completableが正常に完了したときにflatMapCompletableが指定されたアクションを呼び出すと予想していました。しかし、私は思った通りに動作しません。ここに簡単な例があります： PublishProcessor<String> processor = PublishProcessor.create(); processor.flatMapCompletable(s2

0熱

1答えて

改造パラメータを正しく設定するには

改造2を使用して天気アプリを作成しようとしていますが、今度は正しく呼び出しを設定するために苦労します。ここでが働いているURLです：だから http://api.openweathermap.org/data/2.5/weather?q=London&APPID=MY_API_KEY を、私は私のAPIキーとBASEのURLを持っている：http://api.openweathermap.o

4熱

1答えて

RxJava2 - メジャーリーグ、メイベス、コンプリート？

Singles、Maybes、Completablesをマルチキャストするにはどうすればよいですか？それらをマルチキャストするために標準Observableに変換することをお勧めしますか？ Observable<String> strings = Observable.just("Alpha", "Beta", "Gamma", "Delta", "Epsilon");

4熱

1答えて

はRxJava 2

にリストを平らにし、次のように私は、リストの各項目を発することができ、私はしばらくの間RxJava 1を使用しているが、私はRxJava 1ではRxJava 2を見てみたい： List<String> list = ... Observable.from(list) .filter(str -> str.contains("Help") .subscribe(...);

1熱

1答えて

Ageraを使用したフィルタリスト

私はリストを持っていますが、それはある述語に基づいてフィルタリングしたいのですが、フィルタ演算子を使用して 'RxJava'を使って簡単に行うことができますが、それについて明確にする。

11熱

3答えて

改造とrxjava 2.xので空の応答を処理

改造から空の応答を処理するためにObservable<Void>を返すために使用rxjavaの1.xiを使用する場合： @POST("login") Observable<Void> getToken(@Header("Authorization") String authorization, @Header("username") String username,