問題タブ [reactivex]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
ios - RxSwift で型の Observable 配列を別の型の Observable 配列に変換する方法
私はRxSwiftが初めてで、次の状況に遭遇しました:
toArray() は何もしないように思えますが、その理由はわかりません。一方、このコードは私が望むことを行います。前のコードが同じように機能しない理由を知りたいです。
前もって感謝します。
編集:
ビューモデルの実装は次のとおりです。
Country には、City の配列であるプロパティ「cities」があります。
@solidcell toArray() の前後に debug() を配置すると、debug() ごとに 1 つ、および toArray() debug() の前にのみ配列項目ごとに 1 つの次のイベントの 2 つのサブスクリプションが取得されます。
しかし、なぜそれは完了していないのですか?
ios - ReactiveXオブザーバブルを一時停止する方法
iOS/Swift ( RxSwift ) でReactiveXを使用しています。
オブザーバブルがあるとしましょう:
私が購読しているもの:
アニメーション中に更新を受信した場合、アニメーションが終了するまで次の更新を受信したくありません (アニメーション中に発生する更新も失いたくありません)。
したがって、必要なのは、そのdataUpdates
オブザーバブルの放出を一時停止することだけです。
どうすればこれを達成できますか?
javascript - Rxjs で、通常の型と Observable の両方を含むストリームをフラット化またはマージするにはどうすればよいですか?
配列に似ていflatten([1, 2 [3, 4], [5, 6]]) === [1, 2, 3, 4, 5, 6]
ます。
rxjs オブザーバブルでこれを実行したいと思います。
mergeAll は機能せず、エラーがスローされます。
これは非常に汚い解決策です:
これに対するより良い解決策はありますか?
angularjs - 観測可能な値を同期的に取得できますか? (Angular/ReactiveX)
私は自分のプロジェクトで を呼び出すブール値オブザーバブルを持っていますisPossible
。これは宣言された方法です:
これが であるという条件を追加しisPossible
たいtrue
のですが、他の条件が同期的に評価される場所に追加したいのですが、オブザーバブルの値を使用する方法を知っている唯一の方法は、非同期パイプを使用することです...のよう{{isPossible | async}}
に、しかしここで私は同期的に取得する必要があります...どうすればできますか?
java - Rx: onError が呼び出された場合でも最後の要素を取得する方法は?
私は RxJava を使用しており、次の 2 つのことを行う必要があります。
- から放出された最後の要素を取得します
Observable
- が呼び出されたかどうかを判断する
onError
、vs.onCompleted
last
and (これは実際に必要な動作です) の使用を検討しましたが、最後の要素lastOrDefault
を非表示にすることはできませんでした。onError
Observable を 2 回使用しても問題ありません。1 回はlast
値を取得するため、もう 1 回は完了ステータスを取得するためですが、これまでのところ、独自の を作成することによってのみこれを達成できましたObserver
。
私は自分で を作成することに問題はありませんObserver
が、Rx は「完了前に発行された最後の要素を取得する」というこのユースケースをより適切に満たすことができるはずだと感じています。これを達成する方法についてのアイデアはありますか?
android - OnErrorNotImplementedException 原因: rx.exceptions.MissingBackpressureException
syncUsers() メソッドを呼び出すとエラーが発生します。
問題は最初の操作にあるようです。
そして呼び出し:
rx-java - SkipUntil が期待どおりに機能しない
演算子 SkipUntil を探していますが、期待どおりに機能していないようです。これが私のコードです
observable2 にはサブスクライブがないため、演算子 skipUntil を使用して最初のオブザーバブルがすべてのアイテムをスキップする必要があるアイテムを発行していないことを証明しようとしていました。しかし、まだ5つのアイテムすべてを放出しています。
理由は?
ドクターは言います。
javascript - 完了後 n 秒後にリクエスト (Angular2 - http.get) を繰り返します
angular2 をいじって、しばらくすると動かなくなってしまいました。
単一のリクエストに対して使用しhttp.get
ても問題なく動作しますが、かなりの時間をいじって、最終的に多くのreactivexのものを読んだ後、4秒ごとにライブデータをポーリングしたいと思います:
-observable がリクエストの結果を発行した後に (4 秒) 間隔を開始する簡単な方法はありますか? (それとも観測地獄http.get
に落ちてしまうのでしょうか?)
私が欲しいタイムライン:
reactivex - ReactiveX : オブザーバブルを破壊しないエラーハンドリング
Observable が破棄されないように、REactiveX のサブスクライバーにエラーを伝達する方法が不明です。
例
この制限をそのまま受け入れますが、ダウンストリームのリスナーにエラーが発生したことを知らせ、オブザーバブルを死なせたくないというシナリオがまだあります。
これの主な使用例は、エラーが発生した場合に、以前に登録したすべてのオブザーバブルに対して「セットアップ」を呼び出す必要がないようにする UI コードです。
可能な代替手段は次のとおりです。
a) データ フィールドとエラー フィールドを持つカスタム オブジェクトをプッシュする
私はこの解決策が好きではありません
b) 2 つのストリームを持つ。1 つはデータ用、もう 1 つはエラー用です。
これに対する一般的なベストプラクティスは何ですか?