system.reactive

    8

    3答えて

    私はクラスを持っているためにテストが作成されたものと同じスレッドで実行されるのCalcに対するすべての呼び出しを必要と public class Test { public int Calc(); } を観察可能なラッパーを作成します。私は一度Test(高価な操作)を作成しCalcを複数回呼び出す必要があります。それを行うための一つの方法は、BackgroundWorkerのか、

    1

    2答えて

    Rxで問題が発生しました。私は、新しいスレッドの各項目を処理した後、結果をメインスレッドに送る必要があります。私は他の方法でそれをやった。 Rxでこのタスクをどのように解決できますか?ここにコードは Observable.ToAsync<string, IEnumerable<UserState>>(Run)(path) .ObserveOnDispatcher<IEnumerable<User

    5

    5答えて

    アイブ氏は、Rxのライブラリをinvestigingされて、次のビデオからの例を複製しようとしています... http://channel9.msdn.com/blogs/j.van.gogh/writing-your-first-rx-application それは非推奨/変更されているものにいくつかの変更を加えたすべての作品( )彼が使用し、最大まで... .Let(mm => ...)

    8

    1答えて

    私はRx.NETを少し新しくしています。任意の加入者が投げるかもしれない例外をキャッチすることは可能ですか?以下を実行してください... handler.FooStream.Subscribe( _ => throw new Exception("Bar"), _ => { }); 現在、私は次のインスタンスでサブスクリプションごとに捕捉しています。この実装では、待機

    0

    1答えて

    これはのMouseLeftButtonDown後のMouseLeftButtonUpまで、マウスの動きを監視し、私のコードです: var downs = Observable.FromEventPattern<MouseEventArgs>(this, "MouseLeftButtonDown"); var ups = Observable.FromEventPattern<MouseEvent

    0

    1答えて

    私はEventArgsを持つ古典的なEventHandlerではなく、Action<Guid>として定義されたイベントを持つクラスを持っています。これを標準のEventHandlerと同じ方法でIObservableに変換する方法はありますか?他のIObservablesとマージできるように、これを行う必要があります。

    2

    1答えて

    私はいくつかのWCF呼び出しを持っています.A、B、C、D、Eと言うことができます。これらはSLアプリケーションに入っていますなど)。 Aが完了した後にBを実行したいのに対し、Cは同時に実行できます。私は3人すべてが終わった後でDを走らせたい。さらに、条件(単純な場合...)に基づいて、私はEも(上記のいずれかと同時に)実行します。 私はRxをダウンロードして、それがこの仕事のためのツールだと感じ

    3

    1答えて

    SLアプリケーションでRxを使用したいと思います。私は私のウェブサーバーへのREST要求に観測可能なものを設定したいと思っています。私はObservable.FromEventまたはObservable.FromAsyncをワイヤリングする方法を見ていません。私の最高の推測では、Webclientの完了がイベントを発生させ、Observable.FromEventを実行することです。そこには良い方

    0

    1答えて

    誰かがこれを1年前に尋ねましたが、誰もいませんでした。今はありますか?

    2

    1答えて

    はので、すべてのプレイヤーがそうのようにタイマーを持っています this.player.Timer = from tick in TimerPublisher where tick % 1 == 0 select tick; と私はのようないくつかのサブスクライブされたメソッドがあります: this.player.Timer.Subscribe(tick => IncreseStamina()