そういうのは、Subjectかませて、hasObserverだかなんだか、接続中かどうか見分ける方法が用意されてるからそっち使うのがいい