Есть созданный Flowable
без оберток:
Flowable flowable = Flowable.create(..., BUFFER).subscribeOn(newThread());
На него идет подписка (асинхронная):
flowable.subscribe(...);
Через какое-то время
Thread.sleep(...);
на него идет подписка (синхронная):
flowable.blockingSubscribe(...);
В результате flowable
выполняется заново. Как сделать так, чтобы во второй раз приходили значения из уже посчитанного буфера и ожидалось окончание?