rx-java2

0熱

1答えて

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

2熱

3答えて

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

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

0熱

1答えて

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

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

0熱

1答えて

Retrofit2とRxJava2でカスタム例外をスローする方法

Retrofit2とRxJava2を使用するときにカスタム例外をスローする際に問題があります。レトロフィットのAPI レトロフィットアピ定義 public interface BackendInterface { @Headers({"......"}) @POST("international-services/") Observable<BackendRespo

1熱

1答えて

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

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

0熱

1答えて

手作業でRxJavaコンビネラテストをフロー可能にする

だから私は2つのフローラブルの最新結果を組み合わせて何かをしたいというシナリオがあります。特定の条件で Flowable.combineLatest( info, list, BiFunction { ... } ) 、私は再び結果を取得し、前からいくつかの異なるものを行うことができるようにする必要があります。だから私は手動でコンビネー

0熱

2答えて

RxJava2を使用したViewModelのEditText検証

ボタンをクリックしたときにRxJavaを使用してEditTextの検証を実行しようとしていますが、検証をViewModelに移動するとテストがはるかに簡単になります。私はJake WhartonのRxBindingsを使ってUI入力を取得し、RxJava2のFlowable.combineLatestをPublishSubjectとともに使用して、AlertDialogのボタンをクリックするとFl

1熱

2答えて

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

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

1熱

1答えて

Retrofit 2が製造時にnullを返す

Retrofit 2が応答でnullを返す問題を修正しようとしています。面白いのは、エミュレータではすべて正常に動作し、データは受信されて表示されますが、APKをビルドすると、同じことがNullPointerExceptionでクラッシュすることです。私はこれが起こるところの行をコメントしました。マイbuild.gradleの依存関係： compile 'com.squareup.retrofi