0

Есть созданный Flowable без оберток:

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

На него идет подписка (асинхронная):

flowable.subscribe(...);

Через какое-то время

Thread.sleep(...);

на него идет подписка (синхронная):

flowable.blockingSubscribe(...);

В результате flowable выполняется заново. Как сделать так, чтобы во второй раз приходили значения из уже посчитанного буфера и ожидалось окончание?

1 ответ 1

1

Решение оказалось довольно простым.

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

Тогда каждый подписчик будет получать общие результаты и дожидаться конца выполнения.

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.