rx.net

    0

    1答えて

    私は、ローカルファイルシステムにテキストメッセージを保存するヘルパークラスを持っています。このメソッドはTaskオブジェクトを返し、定義によって非同期です。 このメソッドが呼び出されたときを観察できるようにしたいので、バッファのサイズと長さを継続的に監視し、それに基づいて決定を下すことができます。 私はこれをReactive Extension for .NETを使用して実装しようとしています。し

    0

    1答えて

    IObservableでToEnumerable拡張子を使用すると、ユーザーはすべての要素を反復しない可能性があります。その場合Observable.CreateでIDisposableはどのように処理されるのが適切ですか? 引数として、IObservableを直接ユーザーに返すことはできません(この場合、ユーザーはキャンセルを自分で実装することができます)。 private IObservabl

    2

    2答えて

    を放出する力バッファ: var source = new Subject<Price>(); var buffer = source .Buffer(TimeSpan.FromSeconds(30), 5) .Where(p => p.Any()); (加入者への公開)を発する意味のバッファが5または30秒の大きさに達したときに、最後のEMIT以来行っているが起こります。

    1

    1答えて

    熱い観測可能なオブジェクトとIDisposableオブジェクトのベストプラクティスをイベントタイプとして見たいと思います。 私のコードでは、ビットマップオブジェクトをホット観測可能と見なし、いくつかのサブスクライバがあるとします。たとえば : public static IObservable<Bitmap> ImagesInFolder(string path, IScheduler sched

    2

    1答えて

    現在のところ、私は自分のボタンのクリックイベントに対してプレーンな古いデリゲート/イベントオブザーバパターンを使用しています。だから、私はRxに行くと思った。 私の最初の試みはボールだった。私はあなたがWinFormsの例に見る最も簡単な過負荷のために行くだろうと思って: Observable.FromEventPattern<EventArgs>(__navToTestButton, 'clic

    3

    1答えて

    私は最近Reactive Extensionsの作業を開始しました。主にAngular 2を使用してクライアント側で観測されました.Rxのオブザーバブルと非同期のdotnetの概念は非常に似ています。あるものが適用可能で、他がそうでない具体的な例がありますか?それ以外の場合、MicrosoftがRx.Netを導入した理由は他にあります。観測可能なものはReactive Extensionsの核心で

    1

    1答えて

    ツリーのどのサブレベルでもプロパティの変更を観察するにはどうすればよいですか? たとえば、NameおよびChildNodesのプロパティを持つクラスTreeNodeを考えてみましょう。 TreeNodeのサブレベルでNameの変更を確認するにはどうすればよいですか?私が書いたように、私は、DLLのバージョンの問題になってしまった - 私はあなたのコードを実行するために得ることができませんでした /

    0

    1答えて

    System.Web.HttpエンドポイントをIObservableにすることはできますか?それはRouteやAcceptVerbsのような属性を使っている間に行うことができますか? は基本的に、私は私が加入して反応性の拡張機能を経由して、それを処理していますので、IObservableストリームに次のコード例を作りたい: [Route("{id}")] [AcceptVerbs("GE

    0

    1答えて

    を「スライディング」:基本的に 今、これらのイベントが矢継ぎ早に起こることができると私はそれが与えられた時間枠内に少なくとも一度起こったかを知っておく必要があるとして、私は通常どおり var someEventObservable = Observable.FromEventPattern<SomeEventHandler, SomeEventArgs>( handler => this.

    0

    1答えて

    IObservableの子プロパティを持つオブジェクトのIObservableが与えられている場合、メインオブザーバブルをフィルタリングして、のアイテム。 たとえば、次のテストケースには、2つのMyClassを含むIObservableがあります。最初のものは5つの整数と2の2番目のオブザーバブルが含まれています。だから私の質問は、4つ以上の数値を含むインスタンスだけを含むMyClassのIObs