Further factoring of ConnectableObservable behaviour