rx-java

9熱

2答えて

このコードはスレッドセーフですか？ Observable<String> observable = ... // some observable that calls // onNext from a background thread observable .scan(new ArrayList<String>(), (List<String> acc,

11熱

1答えて

rxの作成後に要素を追加Observable

Observableを作成した後に要素を追加するときに、シナリオを実装するにはどうしたらいいですか？オブザーバーのパターンでは、私はちょうどイベントなどを発射するでしょう。アイデアはありますか？ import rx.lang.scala._ val target = Observable(1,2,3,4) val subscription1 = target subscribe(print

7熱

2答えて

AndroidでのRxJavaとランダムな散発的なイベント

私はGuavaのEventBusやOttoを使ったのと同じようにRxJavaを使いたいですが、どうやってそのように機能するのか分かりません。これはシナリオです：私はAndroidアプリにボタンを持っていて、ボタンが押されるたびにRxJavaがObservableを介してイベントを放出したいとしましょう。それはイベントを取得した後、私はサービスreregisterを持っている必要があり、その活動は

11熱

2答えて

アンドロイドrxJavaエラー私はこれを使用する代わりに</p> <pre><code>Observable.create(new Observable.OnSubscribeFunc<T>() {...}); </code></pre> <p>の新しいRXのJavaを使用しています改造

での取り扱い：（による非推奨に） Observable.create(new Observable.OnSubscribe<T>() {...}); を（これが最もとして重要になることが例、チュートリアル、explonationは古いものを使用しています...）さて、私の問題を見てみましょう。私はJavaクラスを持っており、そこから関連する部分があります。 private interface

8熱

1答えて

rxjavaとclojure非同期ミステリー：未来の約束と代理人、oh my

このメモの長さは、事前にお詫び申し上げます。私はそれを短くするためにかなりの時間を費やしましたが、これは私が得ることができるほど小さかったです。私は謎があり、あなたの助けに感謝します。この謎は、私がオンラインサンプルから手に入れた2つの簡単なobservableを介してClojureに書いたrxjava observerの動作に由来します。オブザーバブルオブザーバは、オブザーバのハンドラに同期

9熱

1答えて

RxJava - 無限ストリームを終了する

私はリアクティブプログラミングとRxJavaを探求しています。楽しいですが、私は答えが見つからない問題に固執しています。私の基本的な質問：無限に稼働しているObservableを終了させるための反応的に適切な方法は何ですか？また、私のコードに関する批評や反応的なベストプラクティスを歓迎します。練習として、ログファイルのテールユーティリティを作成しています。ログファイル内の行のストリームはObse