Как начать с Microsoft PixelSense

Вы можете создать Flux напрямую, используя код, который выглядит следующим образом. Обратите внимание, что я добавляю несколько предполагаемых методов, которые вам нужно будет реализовать в зависимости от того, как работает ваш SearchSupplier:

Flux<SearchResultType> flux = Flux.generate(
            () -> new SearchSupplier(this, queryBody),
            (supplier, sink) -> {
                SearchResultType current = supplier.next();
                if (isNotLast(current)) {
                    sink.next(current);
                } else {
                    sink.complete();
                }
                return supplier;
            },
            supplier -> anyCleanupOperations(supplier)
        );