submit

fun submit(item: T): Mono<Void>


fun submit(itemFactory: () -> T): Mono<Void>

Reserves capacity before invoking the factory, once per subscription. Only successful enqueue accepts a request. The factory runs on the submitting thread and must be finite, non-blocking and free of storage I/O. Closing does not wait for a factory that has not yet enqueued its item; when that factory returns, its reservation is released and enqueue fails.