rx-java

5熱

1答えて

"skipWhile"とRxJavaの "repeatWhen"を組み合わせてサーバーポーリングを実装する

RxJavaが本当に好きです。それは素晴らしいツールですが、時にはそれがどのように動作するのか非常に難しいです。私たちはAndroidプロジェクトでRxJavaでRetrofitを使用していますが、次のユースケースがあります。サーバーが何らかの仕事をしているうちに、再試行の間に若干の遅延を伴ってサーバーをポーリングする必要があります。サーバーが終了したら、結果を提供する必要があります。私は成功

5熱

1答えて

RxJavaを使用してリスナーをリアクティブ（Observables）に正しく変換する方法は？

私はAppWarp（http://appwarp.shephertz.com）と呼ばれるマルチプレイヤーゲームクライアントを使用しています。イベントが発生したときにコールバックされるイベントリスナーを追加できます。ここでは、このインターフェイスを実装する必要があるConnection Listenerについて説明します。：ここ public interface ConnectionRequest

16熱

1答えて

subscribeOn（）が別のスレッドで呼び出されていても、メインスレッドで観測可能な実行が行われます

私の活動の中で奇妙な問題が発生しました。私はonActivityResultの写真/ビデオの撮影から戻ってくるときに、ユーザーがカメラに名前を付けることができるダイアログを表示しています。ユーザーが[OK]を押すと、ファイルをコピーする要求されたファイル名を持つサブジェクトにonNext()を送信します（進行状況ダイアログが表示されます）。何らかの理由で、私がsubscribeOn(Sche

6熱

1答えて

Rxjava AndroidSchedulers.mainThread（）はUIスレッドを意味しますか？

私のコードは次のようである： .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(AndroidSchedulers.mainThread()) .subscribe ({ adapter.notifyDataSetChanged() }) が、私はエラーました：その景色に触れることができるビュー階層を作成しのみ元のス

5熱

1答えて

テストのAndroidレルム - 例外

「ルーパーなしスレッドから開かれた」私はレルム（https://realm.io/docs/java/latest/#rxjava）から提供されているドキュメントをオフに基づいて、以下のコードを、持っている public Observable<Foo> getFooById(String id) { realm = Realm.getInstance(realmConfiguratio

9熱

2答えて

Subject.asObservableとは何が良いですか？

なぜRxJavaにasObservableが必要ですか？技術的には、それぞれの科目はすでにObservableです。私は、その後の加入者が使用する放射された値を「記憶」するために必要なので、私はBehaviourSubjectを使用だけ Observable obs = subject;

5熱

1答えて

RxJavaで整備してメインオブジェクトを返す。

retrofit + rxjavaを使ってネストしたapi呼び出しを作成しようとしています。基本的には、ライブラリオブジェクトのリストを構築する必要があります。各LibraryオブジェクトにはAuthorsのリストがあり、各AuthorオブジェクトにはBooksのリストがあります。これが私のjsonの構造です。ライブラリJSON - { title: "Library", items: [

7熱

4答えて

RxJava観察者コードの並列実行

は私がRxJava観測APIを使用して、次のコードを持っています： Observable<Info> observable = fileProcessor.processFileObservable(processedFile.getAbsolutePath()); observable .buffer(10000) .observeOn(Schedulers.c

5熱

2答えて

RxJava Vert.xで連鎖HTTPリクエストを終了するには？

Rx Vert.Xでチェーンされた要求を終了する方法は？ HttpClient client = Vertx.vertx().createHttpClient(); HttpClientRequest request = client.request(HttpMethod.POST, "someURL") .putHeader("content-type

12熱

3答えて

レルム、RxJava、asObservable（）、doOnUnsubscribe（）

私のAndroidプロジェクトでは、realmをデータストレージエンジンとして使用しています。大好きです！私もRxJavaを使用しています。なぜなら「スレッド化」がはるかに簡単になり、「反応的な考え方」全体が本当に好きなからです。大好きです！私はMVPパターン+いくつかの「クリーンアーキテクチャー」アイデアを使用して自分のアプリケーションを構築します。私のInteractorsは、Realm