rx.net

0熱

1答えて

StartWithのような拡張子はありますが、観測可能なシーケンスの終わりはありますか？

私は観察可能なシーケンスに余分な "閉じる"項目を追加したいと思います。観察可能なシーケンスの最後にはStartWithのようなReactive LINQ拡張がありますか？それは最後の要素を発射していないようだが、ここでは、私が何をしたいの近似である： public static IObservable<TSource> EndWith<TSource>(this IObservable<TSo

2熱

1答えて

IObservable <IObservable <T>>をIObservable <IEnumerable <T>>にするにはどうすればよいですか？

私はマウスの左ボタンの状態のためのストリームを持っている： var leftMouseButton = mouse.Select(x => x.LeftButton).DistinctUntilChanged(); 私はその後、Window、これは私のマウスのドラッグを表す観測の観測可能を与える： var leftMouseDrag = mouse .Select(mouseStat

2熱

2答えて

スロットルが遅すぎると結果が破棄されます

ユーザーが検索語を入力できるUIを作成していて、リストには常に提案候補が表示されます。私の最初のことは、Rxの原始的なスロットルは完璧な試合だったが、そこに私の半分を得ることができた。私はUIスレッドではなく非同期的にそれらを取得するので、提案はフェッチするのに時間がかかります。問題は、ユーザーがスロットル時間スパンをもう一度タイプした場合、結果を破棄/スキップ/スローすることです。例えば

1熱

1答えて

CでRXを使った自動保存

自動保存機能を実装したいと思います。私は2つの観測があります IObservable<Unit> changes：アイテムは、ユーザーがテキスト IObservable<Unit> savesを編集するたびに発する：保存イベントに保存ボタンがを押すたびに発する今私は、結合したいです第3ストリームへのそれらwriteBack。このストリームには、現在のテキストをデータベースに書き込むサブスクライバ

2熱

2答えて

FRP（Rx.Net）の循環依存性をどのようにモデル化すればよいですか？

私はTic-Tac-Toeを実装するためにRx.Netを使用して、機能的反応プログラミングについてもっと学びたいと思っています。私が抱えている問題は、ゲームロジックに循環的な依存関係があるように見えることです。ストリーム（PlaceToken,ResetGameなど）は、ユーザー入力ストリームから生成されます。ゲーム（boardStates）の現在の状態が初期状態から開始して、以前の状態にco

4熱

2答えて

Reactive Extensionsを使用して状態をポーリングするにはどうすればよいですか？

反応（Database polling with Reactive Extensions）を使用して、データベース・ポーリングに良い質問がまだあり私は同様の質問を持っていますが、ひねりを加えた：私は、次の要求に前の結果から値を供給する必要があります。基本的に、私はこれをポーリングしたいと思います： interface ResultSet<T> { int? CurrentAsOfHa

1熱

1答えて

リアクティブな拡張機能は、コレクションを返すAPI呼び出しにのみ適していますか？

私は、複数のREST APIを呼び出すプロキシを使用して、UIのコースグレイン出力を作成しています。 UIはKnockoutJSで構築されています。私は非同期的にAPIを呼び出すためにタスク/非同期メソッドを使用しています。 1つまたは2つのAPIだけがリストを返し、他はすべてフラット値のオブジェクトを返します。 Rxはコレクションを返さないAPIの結果を結合するために使用できますか？出力はコレク

2熱

2答えて

Rx.Net GroupByの実装の要素シーケンスがまれにある

私はRX 2.2.5を使用しています。私はこの問題は、それは非常にまれ要素の順序をミスしないことをGROUPBYの後に来る、それはすべての要素のシーケンスを取得する前にGROUPBY _transportService .ObserveSubOrder(parentOrder.OrderId) .SubscribeOn(_backgroundScheduler)

0熱

2答えて

最後にObservable（Sequence）にプッシュされたアイテムを取る

私はクラス内にIObservable<Item>を持っており、与えられた時刻に最後のアイテムを観測可能にプッシュする読み取り専用プロパティを公開したいと思います。したがって、Itemの単一の値を提供します。値がプッシュされていない場合は、デフォルトのの値を戻す必要があります。私は観察可能なものを購読したり、 "バッキングフィールド"を持たなくてもこれを行うことができますか？