ストリームが切れた時に発火するオペレータって無いですか？ doのonErrorとonCompletedに共通の処理を書きたくない。。。