flux

fun <T : Any> flux(request: ServerRequest, result: () -> Flux<T>): Flux<T>

Bounds the execution of a streaming query: applies the idle timeout, fails (a server fault) on more rows than the list limit, and buffers the rows (at most the list limit) unless the client accepts an event stream or the list limit is off, so a late failure still produces an error response. result runs on subscription.