lambdalice/CoreTweet — pull request #1 by azyobuzin (2013-12-28 11:39:57+00:00)
Title: Rx の Streaming の実装を改善しました

# 現状の実装の問題点
* Publish() されているのに返り値の型が IObservable なので Connect() できない
* Connect() でフリーズしてしまう（ToObservable() を使っているから？）

# 変更点
接続部分を Observable.Create を使って書き直しました。 Rx にあまり慣れていないので、正しい書き方なのかはわかりませんが、 Connect() でフリーズすることなく動作しました。