問題タブ [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.

0 投票する
1 に答える
1312 参照

ios - RxSwift で型の Observable 配列を別の型の Observable 配列に変換する方法

私はRxSwiftが初めてで、次の状況に遭遇しました:

toArray() は何もしないように思えますが、その理由はわかりません。一方、このコードは私が望むことを行います。前のコードが同じように機能しない理由を知りたいです。

前もって感謝します。

編集:

ビューモデルの実装は次のとおりです。

Country には、City の配列であるプロパティ「cities」があります。

@solidcell toArray() の前後に debug() を配置すると、debug() ごとに 1 つ、および toArray() debug() の前にのみ配列項目ごとに 1 つの次のイベントの 2 つのサブスクリプションが取得されます。

しかし、なぜそれは完了していないのですか?

0 投票する
1 に答える
1553 参照

ios - ReactiveXオブザーバブルを一時停止する方法

iOS/Swift ( RxSwift ) でReactiveXを使用しています。

オブザーバブルがあるとしましょう:

私が購読しているもの:

アニメーション中に更新を受信した場合、アニメーションが終了するまで次の更新を受信したくありません (アニメーション中に発生する更新も失いたくありません)。

したがって、必要なのは、そのdataUpdatesオブザーバブルの放出を一時停止することだけです。

どうすればこれを達成できますか?

0 投票する
3 に答える
4354 参照

javascript - Rxjs で、通常の型と Observable の両方を含むストリームをフラット化またはマージするにはどうすればよいですか?

配列に似ていflatten([1, 2 [3, 4], [5, 6]]) === [1, 2, 3, 4, 5, 6]ます。

rxjs オブザーバブルでこれを実行したいと思います。

mergeAll は機能せず、エラーがスローされます。

これは非常に汚い解決策です:

これに対するより良い解決策はありますか?

Jsbin http://jsbin.com/vohizoqiza/1/edit?js,console

0 投票する
3 に答える
427 参照

angularjs - 観測可能な値を同期的に取得できますか? (Angular/ReactiveX)

私は自分のプロジェクトで を呼び出すブール値オブザーバブルを持っていますisPossible。これは宣言された方法です:

これが であるという条件を追加しisPossibleたいtrueのですが、他の条件が同期的に評価される場所に追加したいのですが、オブザーバブルの値を使用する方法を知っている唯一の方法は、非同期パイプを使用することです...のよう{{isPossible | async}}に、しかしここで私は同期的に取得する必要があります...どうすればできますか?

0 投票する
4 に答える
2392 参照

java - Rx: onError が呼び出された場合でも最後の要素を取得する方法は?

私は RxJava を使用しており、次の 2 つのことを行う必要があります。

  • から放出された最後の要素を取得しますObservable
  • が呼び出されたかどうかを判断するonError、vs.onCompleted

lastand (これは実際に必要な動作です) の使用を検討しましたが、最後の要素lastOrDefaultを非表示にすることはできませんでした。onErrorObservable を 2 回使用しても問題ありません。1 回はlast値を取得するため、もう 1 回は完了ステータスを取得するためですが、これまでのところ、独自の を作成することによってのみこれを達成できましたObserver

私は自分で を作成することに問題はありませんObserverが、Rx は「完了前に発行された最後の要素を取得する」というこのユースケースをより適切に満たすことができるはずだと感じています。これを達成する方法についてのアイデアはありますか?

0 投票する
1 に答える
2806 参照

android - OnErrorNotImplementedException 原因: rx.exceptions.MissingBackpressureException

syncUsers() メソッドを呼び出すとエラーが発生します。

問題は最初の操作にあるようです。

そして呼び出し:

0 投票する
1 に答える
1016 参照

rx-java - SkipUntil が期待どおりに機能しない

演算子 SkipUntil を探していますが、期待どおりに機能していないようです。これが私のコードです

observable2 にはサブスクライブがないため、演算子 skipUntil を使用して最初のオブザーバブルがすべてのアイテムをスキップする必要があるアイテムを発行していないことを証明しようとしていました。しかし、まだ5つのアイテムすべてを放出しています。

理由は?

ドクターは言います。

0 投票する
4 に答える
9942 参照

javascript - 完了後 n 秒後にリクエスト (Angular2 - http.get) を繰り返します

angular2 をいじって、しばらくすると動かなくなってしまいました。

単一のリクエストに対して使用しhttp.getても問題なく動作しますが、かなりの時間をいじって、最終的に多くのreactivexのものを読んだ後、4秒ごとにライブデータをポーリングしたいと思います:

-observable がリクエストの結果を発行した後に (4 秒) 間隔を開始する簡単な方法はありますか? (それとも観測地獄http.getに落ちてしまうのでしょうか?)

私が欲しいタイムライン:

0 投票する
2 に答える
520 参照

reactivex - ReactiveX : オブザーバブルを破壊しないエラーハンドリング

Observable が破棄されないように、REactiveX のサブスクライバーにエラーを伝達する方法が不明です。

この制限をそのまま受け入れますが、ダウンストリームのリスナーにエラーが発生したことを知らせ、オブザーバブルを死なせたくないというシナリオがまだあります。

これの主な使用例は、エラーが発生した場合に、以前に登録したすべてのオブザーバブルに対して「セットアップ」を呼び出す必要がないようにする UI コードです。

可能な代替手段は次のとおりです。

a) データ フィールドとエラー フィールドを持つカスタム オブジェクトをプッシュする

私はこの解決策が好きではありません

b) 2 つのストリームを持つ。1 つはデータ用、もう 1 つはエラー用です。

これに対する一般的なベストプラクティスは何ですか?