system.reactive

1熱

1答えて

Rx.NET TakeUntil例

以下example var subject = new Subject<int>(); var otherSubject = new Subject<Unit>(); subject .SkipUntil(otherSubject) .Subscribe(Console.WriteLine,() => Console.WriteLine("Completed")); subject.O

system.reactive 2017-03-31

---

0熱

1答えて

放ち値一定の条件が満たされた場合にのみ、他の私はとのViewModelを持って

別vlaueを発する次：私がやりたい何 enum Detection {NotTriggered, Triggered}; public Detection AlertState => _alertState.Value; public DateTimeOffset? LastAlertTime => _lastAlertTime.Value; 別のプロパティ：があり、デフォルトで0を返します。し

system.reactive reactiveui 2017-04-03

---

2熱

3答えて

Reactive Extensions（Rx.Net）を使用して値を待つ方法または一定の時間が経過するまで

時間が経過するか、別のストリームが値を送信するまでスレッドを待機（ブロック）したい以下ではこれを実現するかもしれないが、最初のストリームが空であるため、それが例外をスローし、 // class level subject manipulated by another thread... _updates = new Subject<Unit>(); ... // wait for up to

c# system.reactive 2017-04-04

---

1熱

1答えて

複数の呼び出しに関するIConnectableObservable.Connectの契約

複数回呼び出されたときにIConnectableObservable.Connectの契約とは何ですか？ 返されたIDisposableは、OnCompletedを公開するか、接続を切断してConnectをもう一度呼び出すことを許可する必要がありますか？ 第が廃棄される前に接続が、それは、第二の時間べきで呼び出された場合： スロー おそらくコード リターンの異なる領域からの予期しない処分を有する戻

.net system.reactive observable 2017-04-06

---

3熱

1答えて

Observableがどの項目もプッシュしないと主張する方法を教えてください。

Observable.Neverのような単位テストシーケンスの仕方を知りたいです。 何もシーケンスにプッシュされないことを確認するにはどうすればよいですか？

c# .net system.reactive observable 2017-04-07

---

5熱

1答えて

C＃のobservablesのif/then/else演算子はありますか？

手作り反応拡張（.Net/C＃）のif/then/else演算子の適切な置換えを知っている人はいますか？ numbers.If( predicate: i => i % 2 == 0, thenSource: i => Observable .Return(i) .Do(_ => { /* some side effects */ }) .Delay

c# .net system.reactive 2017-04-11

---

0熱

1答えて

観測可能時間間隔でサブスクライブ結果が表示されない

この観測可能なシーケンスに時間間隔を追加しようとしています（特定の時間間隔で整数シーケンスを生成します）が動作していないようです。私は時間を削除すると、時間が動作します。タイマを誤って適用していますか？ var timer = Observable.Interval(TimeSpan.FromSeconds(2)).Take(4); var nums = Observable.Range(1,1

c# system.reactive 2017-04-13

---

0熱

1答えて

SelectMany observablesを選択する必要があるとき、正しい方法で考えていますか？

したがって、私はSubjectを使用していて、おそらく使用するかどうかわからないので、次のコードに関するいくつかの質問に終わる可能性があります。 これは私が説明するのが難しいです、私はなぜ、私は専門用語が不足しているのかわかりません。 私がしようとしているのは、いくつかのオブザーバブルを登録することができる1つのタイプです。このタイプを渡して、すべてのオブザーバブルをグループ化し、それから単一のオ

c# system.reactive 2017-04-13

---

3熱

2答えて

最初の非同期応答を最も速く（残りの部分を実行しないで）取得するにはどうすればよいですか？

セットアップは次のとおりです。特定の値が正しいかどうかを返す連邦リモートサービスがあります。リモート・サービスへのリクエストにつき最大50件のリクエストを希望どおりに送信できます。 正しい値のみを使用する必要があり、可能な値のセットが小さい（〜700）ため、15またはそれ以上の50のバッチリクエストを送信でき、正しい値が結果セットの一部になります。そのように、私は次のコードを使用しました： Obs

c# wcf async-await system.reactive observable 2017-04-13

---

2熱

1答えて

CombineLatestを使用して複数のグループの3つのイベントストリームを関連付ける

私は、観測可能な3つのイベントストリーム（日付順）（主なイベント、顧客に関するイベント、販売に関するイベント、顧客に関するイベント）各イベントにはvehicleIDとその他のさまざまなプロパティがあります。イベントは1台の車両に表示され、次に別の車両などに表示される可能性があります。基本的に、VehicleIDに基づいて3つの独立したイベントストリームを相互に関連付けるようにしています。私はどのよ

c# system.reactive reactive-programming 2017-04-17

---