Observable.Createは、オブザーバーを引数としたラムダ式に、Subscribe時の実行したい処理を書く。
Observable.Create Method (System.Reactive.Linq) | Microsoft Docs
Reactive Extensions再入門 その３「IObservableのファクトリメソッド」 - かずきのBlog@hatena
とすると、
Observable.Create 1 Observable.Create 7 Observable.Create 2
最初、
Observable.Create 1 Observable.Create 7 Observable.Create 2 Observable.Create 3 x = 1 Observable.Create 4
3秒後、
Observable.Create 1 Observable.Create 7 Observable.Create 2 Observable.Create 3 x = 1 Observable.Create 4 Observable.Create 5 Complete. Observable.Create 6 End. Observable.Create 8 Observable.Create 2
6秒後、
Observable.Create 1 Observable.Create 7 Observable.Create 2 Observable.Create 3 x = 1 Observable.Create 4 Observable.Create 5 Complete. Observable.Create 6 End. Observable.Create 8 Observable.Create 2 Observable.Create 3 x = 1 Observable.Create 4
9秒後、
Observable.Create 1 Observable.Create 7 Observable.Create 2 Observable.Create 3 x = 1 Observable.Create 4 Observable.Create 5 Complete. Observable.Create 6 End. Observable.Create 8 Observable.Create 2 Observable.Create 3 x = 1 Observable.Create 4 Observable.Create 5 Complete. Observable.Create 6 End. Observable.Create 9 続行するには何かキーを押してください . . .
12秒後となる。
戻り値のアクションのところ("End."を出力しているところ。)に、Dispose処理を書くらしい。
Sample/rx/Observable/Create/src/Observable_ at master · bg1bgst333/Sample · GitHub
