Rx 周りをいろいろ改善

* 引数の順番を修正
* IObservable を返して利用者が Publish() するほうが適切だと思った
* 接続が確立する前に Dispose されると Task が終了しないのを修正
* RawJsonMessage の MessageType が Delete になっていた

コミットメッセージが糞なのは許してください＞＜