Rx の Streaming の実装を改善しました

# 現状の実装の問題点
* Publish() されているのに返り値の型が IObservable<T> なので Connect() できない
* Connect() でフリーズしてしまう（ToObservable() を使っているから？）

# 変更点
接続部分を Observable.Create を使って書き直しました。 Rx にあまり慣れていないので、正しい書き方なのかはわかりませんが、 Connect() でフリーズすることなく動作しました。