system.reactive

    1

    1答えて

    アクションコールバックをとる2つの非同期メソッドがあります。アクションのためにRxに拡張機能があるかどうか疑問に思っていましたか? 私の目標は、両方のコールバックが呼び出されるまで待ってから何らかの処理を行うことです。

    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

    2

    2答えて

    私はReactiveUIフレームワークをSilverlightプロジェクトで使用し始めており、ReactiveCommandsを扱うための助けが必要です。私の見解モデルで 、私は大体このようなもの(これは単なる簡単な例である)があります。 public class MyViewModel : ReactiveObject { private int MaxRecords = 5;

    1

    1答えて

    MSDNのドキュメントによれば、次のコードはコンソールウィンドウに '5'を出力します。代わりに何も表示されません。 static void Main(string[] args) { var o = new ReplaySubject<int>(); o.OnNext(0); o.OnNext(1); o.OnNext(2); o.OnNex

    5

    1答えて

    私はRxを読んでいると思います。特定のサービスを非同期に6回呼び出す必要があるSilverlightアプリケーションがあります。昔は、呼び出しを行い、userState/tokenを照会することで、要求との応答が一致するようにしました。これらの呼び出しは、呼び出された順に返されることは保証されていないからです。しかし、私はRxがはるかにエレガントな方法でこれを処理すると思われます。しかし、私はそれ

    3

    1答えて

    を続行できますがIObservableをしていると仮定しますか? IObservable<long> resilientObs = obs.Catch(obs); したがって、例外がキャッチされた場合は、例外を生成したのと同じシーケンスを続行します。

    1

    1答えて

    次のコードがあります。私のメソッドには文字列の戻り値の型があります。 public string GetRedemeptionNumber() { string _batchNumber = "test"; var _loadBatchName = Observable.ForkJoin(_context.QuerySingleOrDefault( _context.GetRe

    3

    2答えて

    私はIObservableを持っています。プロパティの変更には、エンティティIDとPropertyNameがあります。これを使ってデータベースを更新したいのですが、複数のプロパティがほぼ同時に変更された場合、同じエンティティのすべてのプロパティに対して1つの更新を行いたいだけです。これは、静的IEnumerableをしたと私は単純に使用することができますLINQを使用していた場合は : MyLis

    2

    2答えて

    msdnでHTTP POSTの例を見つけましたが、こちらでどのように反応拡張を利用できるのでしょうか? using System; using System.Net; using System.IO; using System.Text; using System.Threading; class HttpWebRequestBeginGetRequest { private