RxJava 2 - повторная подписка на буфер
420
27 января 2017, 05:39
Есть созданный Flowable без оберток:
Flowable flowable = Flowable.create(..., BUFFER).subscribeOn(newThread());
На него идет подписка (асинхронная):
flowable.subscribe(...);
Через какое-то время
Thread.sleep(...);
на него идет подписка (синхронная):
flowable.blockingSubscribe(...);
В результате flowable выполняется заново. Как сделать так, чтобы во второй раз приходили значения из уже посчитанного буфера и ожидалось окончание?
-
18:43
Продвижение своими сайтами как стратегия роста и независимости
-
22:46
-
06:18
-
12:23
-
20:41
-
06:31
-
21:28
-
22:18
-
08:00
ТОП-10
- Почему SERVER_ADDR имеет не тот IP 50013 visits
- Как заменить $_SERVER[REMOTE_ADDR] на IP клиента в PHP за двумя Nginx? 31913 visits
- Хочу вывести несколько строк из массива в один div, выводит только много undefined; подскажите, что делать? 25972 visits
- Как через css изменить цвет png изображения? 11734 visits
- Blob video url download 11281 visits
- Php curl запрос через прокси с авторизацией 10685 visits
- Работа с captcha vk api 9481 visits
![Как юзать либу MaterialDrawer [требует правки]](https://hostciti.net/images/nophoto.png "Как юзать либу MaterialDrawer [требует правки]")
© "hostciti.net" 24.1.2026 | 18:41