Package-level declarations

Types

Link copied to clipboard
interface MonoFunctionAccessor<T, out R : Mono<*>> : ReactiveFunctionAccessor<T, R>

Interface for accessing functions that return Mono reactive streams. Specializes ReactiveFunctionAccessor for Mono-specific operations, providing type safety for single-value reactive returns.

Link copied to clipboard

Creates the MonoFunctionAccessor of a message function: one accessor type for every return shape, adapting the result with the ResultAdapter chosen for the function's declaration.

Link copied to clipboard
interface ReactiveFunctionAccessor<T, out R : Publisher<*>> : FunctionAccessor<T, R>

Interface for accessing reactive functions that return Publisher-based types. Extends FunctionAccessor to provide reactive stream support for functions that return reactive types like Flux, Mono, or other Publisher implementations.

Functions

Link copied to clipboard
fun <T : Any> Mono<T>.toBlockable(scheduler: Scheduler = Schedulers.boundedElastic()): Mono<T>

Subscribes this Mono on scheduler when it is subscribed from a non-blocking thread, so blocking work does not stall an event loop; elsewhere it runs where it is subscribed.

Link copied to clipboard