АД
в реакторе ты и так ничего не ждешь, у тебя событийная модель. для твоего кейса нужен ExecutorService или иной вариант.
Size: a a a
2020 April 15
Ds
А как запускать из текущего треда моно и не дожидаться его выполнения??
Засабмить его в другой тред пул. посмотри ExecutorService
w
Засабмить его в другой тред пул. посмотри ExecutorService
То есть subscribeOn(threadPool)
Ds
То есть subscribeOn(threadPool)
w
В реакторе есть уже готовое решение?
w
Ну да publishOn/subscribeOn.
АД
Ну да publishOn/subscribeOn.
это не поможет, методы не для фонового выполнения
w
это не поможет, методы не для фонового выполнения
Почему? Методы будут вызываться на другом экзекьюторе, а последний subscribeOn будет триггерить всю цепочку
АД
subscribeOn ничего не триггерит, нужно все равно вызвать подписку
w
Mono.subscribeOn().subscribe()
w
subscribeOn ничего не триггерит, нужно все равно вызвать подписку
+ да
АД
будет тоже самое что изначально ты писал)
w
Нет, будет на другом тред пуле
w
Текущий не будет блочиться.
w
Subscribe возвращает disposable.
АД
Subscribe возвращает disposable.
да, я не прав тут оказался(
w
Спасибо за дискуссию! Меня просто переклинил этот кусок, хотя я уже год на реакторе пишу, до этого лет 5 на скале.
w
С реактором просто какие-то штуки все-таки сложны, то ли из-за того что он ленивый, то ли просто я туповат.
А
Возможно стоит посмотреть в сторону котлина и его корутин?