関連: リスト上の非同期関数
私はこのような関数を持っています:
public async Task<decimal> GoToWeb(string Sym){}
1分に1回、文字列のリストを介して定期的に呼び出したいと思います。これをReactiveExtensionsObservableに変換するにはどうすればよいですか?
関連: リスト上の非同期関数
私はこのような関数を持っています:
public async Task<decimal> GoToWeb(string Sym){}
1分に1回、文字列のリストを介して定期的に呼び出したいと思います。これをReactiveExtensionsObservableに変換するにはどうすればよいですか?
リアクティブ フレームワークは非同期を処理できるため、次の方法を試すことができます。
var syms = new List<string>() { "ANZ", "BHP", };
var query =
from i in Observable.Interval(TimeSpan.FromSeconds(1.0))
from sym in syms.ToObservable()
from d in GoToWeb(sym).ToObservable()
select new
{
Symbol = sym,
Value = d,
};
タスクSystem.Reactive.Threading.Tasks
の拡張機能を取得するには、名前空間への参照を追加する必要があります。ToObservable()
これはあなたのニーズを満たしていますか?