手動で変換するなら Observable.create の中で do(onDisposed) に observer ひっかける？