вызов БД Cassandra это как-то на что-то повлияет в этом реактивном потоке? Или лучше реактивно ходить в касандру, но тогда как фильтровать основной поток на базе результата из касандры?
Реактивный фильтр с синхронным и/о-сайдэффектом это прям сомнительное решение, кмк
Согласен, поэтому и спрашиваю. Тогда как-то не фильтром сделать а через flatMap и вернуть Mono<Boolean> чтоль или как?
Поставь на filter IO шедулер
А это как, есть пример или ссылка?
Обсуждают сегодня