UniRxのCreateを使う

Observable.Create<T>ではobserverが渡ってくるので、それを使って柔軟にStreamを発火させる。
戻り値にDisposableが必要なのでDisposable.Create(~)でDisposableを作成し返している。

Create

        var createStream = Observable.Create<int> (observer => {
            observer.OnNext (0);
            observer.OnCompleted ();
            return Disposable.Create (() => {
                print ("Dipose");
            });
        });

        createStream.Subscribe (hoge => print ("test1:" + hoge));