Package-level declarations

MonoFunctionAccessor wrapper that handles blocking operations by scheduling them on a separate thread. This accessor is used for functions annotated with @Blocking to ensure they don't block the reactive event loop. It automatically switches to a bounded elastic scheduler when running on a non-blocking thread.

MonoFunctionAccessor for functions that return Flux streams. This accessor converts Flux results to Mono> by collecting all emitted items into a list, providing a way to handle multi-value reactive streams in a Mono context.

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

Factory object for creating MonoFunctionAccessor instances based on function return types. Automatically determines the appropriate accessor implementation based on the function's return type and any blocking annotations.

MonoFunctionAccessor for functions that return Publisher streams. This accessor converts Publisher results to Mono by taking the first emitted item, providing compatibility with the Reactive Streams specification.

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.

Simple implementation of MonoFunctionAccessor for functions that already return Mono. This accessor defers the execution of the underlying function to ensure proper reactive stream behavior and lazy evaluation.

MonoFunctionAccessor for synchronous functions that don't return reactive types. This accessor wraps synchronous function calls in Mono.fromCallable to provide reactive stream compatibility while executing the function on a blocking thread.

Extension function that makes a Mono blockable by scheduling it on a separate thread if needed. If the current thread is non-blocking (reactive), it subscribes the Mono on the provided scheduler. If already on a blocking thread, returns the Mono unchanged.

Extension function that converts a Kotlin function to a MonoFunctionAccessor. Provides a convenient way to create accessors for functions that should return Mono streams.