rx-java

0熱

2答えて

Observableには、flatMap()のような関数内で発生する例外をスローする方法がありますか？ Javaではは、通常の機能に、あなたはそれが例外をスローすることがあることを指定することができます public void dangerousFunction() throws IOException {} flatMap()ようObservable機能の中で、私は同様の構文を見つけるよう

0熱

1答えて

RxJavaを使った同期シーケンス

RxJavaで次のように表現する方法は苦労しています。 PublishSubject<List<Packet>> packetsSubject = ...; そして、私は、次の送信機能を持っている：：さんは私がネットワーク上で送信するパケットリストのストリームを持っている想像してみましょう public Observable<Status> transmit(Packet p) {...}

0熱

2答えて

複数のオブザーバブルの結果を結合する

私は次のようなことを達成しようとしています： - 2つの異なるAPI呼び出しを行い、結果をリストに結合します。各呼び出しの結果はHashMapであり、リストに変換する関数があります。私が今しようとしているのは、リストを1つにまとめることですが、難しいです。これは私のレトロフィットサービスは、次のようになります。このように（これはよりよく行うことができるなら、私を修正してください）私は別に呼び出し

2熱

3答えて

正しいスレッドからRxJava2を取り消し/使い捨てにする

私はResourceからemmits行を観測しています。問題は、このリソースは実際に作成された別のスレッドからクローズされたくない（子犬を殺し、例外が発生したときに例外をスローする）ことです。私はサブスクリプションを廃棄する場合に観察がSchedulers.io()に加入したが、リソースCancellable/Disposableは、mainスレッドから呼び出されます。ここではKotlinコ

0熱

1答えて

ソースからの登録を解除しないでRxJavaのタイムアウト

TimeoutExceptionがスローされたときに私は嫌いではないが、熱い観測可能なものを購読して、timeout演算子を適用しているが、私はソースが最終的に新しいアイテム）。それをどうすれば実現できますか？私はonErrorReturnとタイムアウトを組み合わせようとしていますが、これもまたサブスクライバーでonCompleteコールを引き起こします。

5熱

1答えて

非同期、Javaの9

のベクトル/ストリームデータの構成可能な戻り値は、ウィジェットを見つけたり、構築します、私はいくつかのクエリ基準に基づいて、APIを持って言う： Widget getMatchingWidget(WidgetCriteria c) throws Throwable （同期）クライアントコードのルックス以下のような： try { Widget w = getMatchingWidget

0熱

2答えて

Observableを使ったRetrofit2の並列レスポンス処理

私はユーザーが登録後にプロフィールを編集できるアプリケーションに取り組んでいます。問題は、プロファイルの編集で複数のAPIコールがバックエンドに使用されることです。電子メールを編集するためのもの、パスワードを編集するためのものなど。私はRxJavaと一緒にretrofit2を使用しているので、呼び出しはObservables/Singlesです。ユーザーが編集ボタンを押して、呼び出しが別のスレッド

1熱

1答えて

RxJava：observableが終了したときを知り、ブール値を返します。

RxJavaを初めて使用しています。私の経験は、主にそれらのチュートリアルからです： Hereとhereです。今、私はRetrofit2でAPI呼び出しを受けて、Obesrvable<AccessToken>を返す状況に遭遇しました。 Authenticatorと呼ばれるクラスは、クライアントからの #authenticateWithClientCredentials()を呼び出します publ

0熱

1答えて

observable emitがキャッシュされたBehaviourSubject値であるかどうかを知る方法？

im BehaviourRelayをソースとして使用すると、サブスクリプション時に最後にキャッシュされた値が放出されるのが好きなので、showPlayingState（mPlayStateManager.getCurrentState（））を手動で呼び出す必要はありません。しかし、これは、onCreateを購読するとエミットされるこのキャッシュされたエミットでアニメーションを実行したくないので、

1熱

2答えて

RxJavaで既存のデータを更新して保持する

RxJavaを使用するために私の（Android）アプリケーションでいくつかのロジックを変換しようとしていますが、もっと高度なロジックを実行する方法を考え出すのに苦労しています。ユースケースは次のとおりです。私はある種のフィードをユーザーに表示したいと思います。フィードはさまざまなソースからの項目で構成されています。メッセージ、記事などが含まれます.APIの制限により、アプリ自体は個々のソースを