プログラムの事とか

お約束ですが「掲載内容は私個人の見解です」

Reactive Extensions

ReactiveExtensionsのThrottleの中でOnNextを呼んではいけない

はいやらかしました まずはこちらのコードでどうなるか static Subject<int> _subject; static void Main(string[] args) { _subject = new Subject<int>(); _subject.Subscribe(Func); _subject.OnNext(0); Console.ReadKey(); } static void Func(int i) { Console.W</int></int>…

Reactive Extensions使って非同期に読みながら非同期に書き込む処理を書いたけど書けなかった話

Rxすごい!便利!と思い始めて早数年。 いまだにWhereとかThrottleとか使う程度です。難しいの書けません。ぎりぎり読める程度です。 それでも使っていなきゃ使えるようにはならないので頑張るのです。 非同期で読み続けるデータを非同期に書き込みたい こん…