Консоль ничего не печатает после исключения этих кодов
ConnectableObservable o = ConnectableObservable.create(emitter -> {
emitter.onNext("first");
Thread.sleep(6000);
emitter.onNext("second");
}).publish();
o.connect();
o.subscribe(
msg -> Log.i(TAG, "" + msg),
throwable -> Log.e(TAG, "", (Throwable) throwable)
);
Но Док сказал
Вы также можете использовать метод соединения, чтобы дать команду Observable начать испускать элементы (или начать генерировать элементы, которые будут испускаться) даже до того, как подписчик на него подписался.