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