There is a Flowable without wrappers:

 Flowable flowable = Flowable.create(..., BUFFER).subscribeOn(newThread());

It is a subscription ( asynchronous ):

 flowable.subscribe(...);

After a while

 Thread.sleep(...);

subscription to it ( synchronous ):

 flowable.blockingSubscribe(...);

As a result, flowable is performed anew. How to make so that values ​​from already counted buffer came the second time and the termination was expected?

    1 answer 1

    The solution was quite simple.

     Flowable.create(..., BUFFER).subscribeOn(newThread()).replay().autoConnect();

    Then each subscriber will receive general results and wait for the end of the execution.