reactivex

1熱

1答えて

現在、RxSwift Observablesを使用しているときに複数のネットワーク要求が実行されている問題が発生しています。私は、冷たい観察可能なものを作成し、複数の観察者がいる場合、観察可能なものは、購読するたびにそのブロックを実行することを理解しています。ネットワーク要求を一度実行する共有サブスクリプションオブザーバブルを作成しようとしましたが、複数のサブスクライバに結果が通知されます。以下

1熱

1答えて

Observable.deferのオブザーバーのonNextメソッドを呼び出す

私は新しいリアクティブプログラマーです。私は観測者のonNextメソッドを延期して呼びたいと思っていました。使用すると、1人の加入者からのみをonNext呼び出すことができますので、例 - Observable.create(new Observable.OnSubscribe<Integer>() { @Override public void call(Subscribe

0熱

2答えて

RxJava：subscribeOnとobserveOnが期待通りに動作しない

おそらく私はsubscribeOnとobserveOnの内部動作を理解しているかもしれませんが、最近私は本当に奇妙なことに遭遇しました。私は、subscribeOnが最初に処理を開始するスケジューラを決定しているという印象を受けました。特にmapが多くあり、observeOnはスケジューラを変更するときにmapsのどこでも使用できます最初にネットワーキングを行い、計算し、最後にUIスレッドを変更し

2熱

1答えて

ReactXにイベントを記録するにはどうすればいいですか？

私はいくつかの従来のイベント発行者によって呼び出されるイベントコールバックメソッド public void onSomethingHappened(Information info) { を持っています。これをReactiveXで包み込みます。これを行う方法？ UPDATE 私はPublishSubject<T>クラスを発見し、AndroidのAPIからLocationListenerをラ

0熱

2答えて

申し込み時に例外が発生した場合はどうなりますか？

RxJavaに「サードパーティ」パブリッシャーをラップしようとしています。購読中に、私は出版社を準備しており、これにより例外が発生する可能性があります（出版社が利用できない場合）。例外はどうしたらいいですか？ 1）subscribeメソッドからスローしますか？ 2）オブザーバーのOnErrorメソッドにプッシュしますか？ 3）他に何か？私はOnErrorにプッシュすることを考えています。サブス

2熱

1答えて

誰がReactiveXでリンクを保持していますか？

JavaのPropertyChangeSupport observableでオブザーバーのリストを管理します。したがって、observableが削除された場合、observerはガベージコレクションの対象です。したがって、観察可能なものはリンクを保持しています。 ReactiveXではこれが当てはまらないという印象があります。 observableはsubscribeメソッドを持っていますが、S

2熱

1答えて

takeWhileを使用して最後の要素をエミュレートする方法は？

私は要素から項目を放出するストリームを持っています。私はどの要素があるか知っています。その要素がエミュレートされると、ストリームはより多くを放出しない。問題は、それがonCompleteを発行しないということです。私はtakeWhileのようなものが必要ですが、最後の要素も生成しています。これは、ビー玉と考えです：オペレータまたはオペレータが、私はこれを行うために使用することができます（オリジナ

1熱

2答えて

combineLatestのようになりますが、withLatestFromのように動作するRx演算子

Observablesは、Observablesが要素を放出するまで何も放出しないように2つを組み合わせた演算子を探していますが（combineLatestに似ています） 1つのObservableは、もう1つのObservableの最後に放出された要素を持ちます（withLatestFromに似ています）。結果は、（観測可能yは「コントロール」である）、次のようになります。を、このようなオペレ

0熱

1答えて

変化検出角度2モデルのプロパティ

私のモデルのプロパティーが変更された場合は、毎回JQuery関数を呼び出す必要があります。一例として person = {firstName:firstName, lastName:lastName} 私は、私は機能を起動する必要があるたびに、人物オブジェクトのfirstNameのプロパティを変更した場合。実際には、このオブジェクトのプロパティのサブスクリプションのようなものが必要です。どう

7熱

3答えて

リアクティブプログラミングでのストリーム間の依存関係のサイクル

リアクティブプログラミングでは、2つのストリームが互いに依存する状況によく遭遇します。これらのケースを解決するための慣習的な方法は何ですか？最小限の例：ボタンAとBがあり、どちらも値を表示しています。 Aをクリックすると、Aの値がBで増加する必要があります。Bをクリックすると、Bの値をAに設定する必要があります。最初の解決方法F＃の例がありますが、任意の言語の回答は歓迎します。 let sol