rx-java

25熱

1答えて

アンドロイドのEventBusとRxJavaの違いについて私は混乱しています。いくつかの変更が行われたときにコンポーネントに通知することについて、自分の状態を更新できるように、私の問題のためにそれらの1つを実装する必要があります。また、EventsBusがRxJavaで廃止され、この情報が真であるかどうかわかりません。

5熱

2答えて

不正なスレッドからのレルムアクセスcopyFromRealmを使用してコピーが送信されたときの例外

レルム参照の代わりにレルムオブジェクトのコピーをストリーミングし、Schedulers.IOスレッドで観察すると、有名な例外メッセージ "Realm access from incorrect thread Realmオブジェクトは作成されたスレッドでのみアクセスできます。スレッドは空きであってはいけませんか？あるスレッドからそれを生成し、それを別のスレッドで処理することはできますか？これは、

5熱

1答えて

イベントループのオブザーバブルを作成する

最近rx-javaについて少し読んでいます。フレームワークがスレッド間の通信システムの請求書に適合しているかどうかは疑問です。私はJavaで書かれたRESTサーバーに取り組んでいます。いくつかのリソースがPUT/POSTされるたびに、私はワーカースレッドのプールを使っていくつかの計算をしたいと思います。しかし、私は依然としてリクエストを監視することができ、おそらくいくつかの統計情報を出力することが

20熱

2答えて

複数の利用者が閲覧可能なシングル

私はをRetrofitサービスから作成し、 .getFoo()メソッドを呼び出した後、複数のサブスクライバと共有する必要があります。ただし、.share()メソッドを呼び出すと、ネットワークコールが再実行されます。リプレイオペレータは動作しません。私は潜在的な解決策が.cache()かもしれないことを知っていますが、なぜこの動作が引き起こされるのかわかりません。 Retrofit retrofit

5熱

1答えて

複数スレッドからの先物 - onNextから観測可能

Futuresのリストの結果からObservableをリアルタイムで生成したいと思います。私はFuture.sequenceで実行している先物のリストを持っていて、完了するたびに通知するObservableで進捗を監視しています。私は基本的に次のようにしています： def observeFuturesProgress(futs: List[Future[Int]]) : Observable[S

5熱

1答えて

RxJavaは、彼らが一致する属性を持っているとき、私はこれらの上参加することができますどのように私は2つの観察可能なストリーム <pre><code>Observable<Book> books; Observable<Movie> movies; </code></pre> <p></p>を考えてみましょう属性値

を照合することによって観察可能なストリームに参加しますか？以下psudoコードのようなもの：それを行うの Observable<BookMoviePair> pairs = books.join(movies) .where((book, movie) -> book.getId() == movie.getId())) .return((book, movie) -> new

7熱

1答えて

RxJava：Observableに条件付きでチェーンを壊さずに演算子を適用する方法

RxJava観測で演算子の連鎖があります。私は "チェーンを壊す"ことなく、ブール値に応じて2つの演算子のうちの1つを適用できるようにしたいと考えています。私はRx（Java）には比較的新しいので、私は現在の一時変数を導入するアプローチよりも、おそらくもっと慣用的で読みやすい方法があると感じています。ここではそれ以外の場合はtoList()で無制限のサイズの単一のバッチを放出する、バッチサイズ

0熱

2答えて

Rx JavaでObservable.from（）演算子を適用した後で項目を再連結します

の位置のリストを出力するObservableがあります。これらのLocationオブジェクトはユーザ（実際には？）を返すメソッドgetUser()を持っています。私がしようとしているのは、Locationオブジェクトのこのリストを与えられたUserオブジェクトのリストを発行する新しいObservableを返すことです。ここに私のコードです：観察可能場所は private Observable<L

1熱

1答えて

RxJavaでスレッディングを使用するには？

Observable.create(new Observable.OnSubscribe<Integer>() { public void call(final Subscriber<? super Integer> obs) { new Thread(){ public void run(){ obs.onNext(1);

0熱

1答えて

RxScalalはマルチオブザーバーと契約しています

私はマルチを使用しようとしていますObserverObservableonNextループ内で発生しました。すべてのオブザーバーにとってうまくいかないようです。 import rx.lang.scala.Observable object SubscribeMultiEvent extends App{ val obv = Observable.apply[String]{ s =>