First thought is to use an Observable<boolean> to switch between an empty stream and the real one.