Как получить элементы из joinLatest для потоков, подмножество которых может быть пустым ⇐ JAVA

[Anonymous]

Я использую метод Flux.combineLatest(combinator,stream1,stream2, ...) для получения последних элементов из каждого входного потока.
Это будет генерировать элемент только тогда, когда каждый входной поток выдает хотя бы одно значение, другими словами, ни один элемент не будет вытекать, если есть хотя бы один пустой поток, тогда как я объединяю потоки с двумя типами данных:

• один, который должен содержать данные до того, как joinLatest выдаст
• другой, который является необязательным - отсутствие элементов в нем не должно блокировать выбросы от joinLatest

Как только необязательные потоки начнут выдавать данные, с ними следует обращаться так же, как с другими потоками с необходимыми данными.
Я просмотрел документацию Reactor и не смог найти подходящего оператора, который выполнил бы эту работу.
Единственное решение, которое у меня есть, — это добавить (

Код: Выделить всё

startWith

) необязательные потоки с некоторыми фиктивными данными, которые я бы затем идентифицировал и исключил в функции комбинатора, но меня это не очень привлекает.

Подробнее здесь: https://stackoverflow.com/questions/726 ... n-be-empty