wow-core/me.ahoo.wow.infra.accessor.function.reactive/SyncMonoFunctionAccessor

SyncMonoFunctionAccessor

data class SyncMonoFunctionAccessor<T, D>(val function: KFunction<*>) : MonoFunctionAccessor<T, Mono<D>>

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.

Parameters

the type of the target object

the type of data in the Mono

Constructors

SyncMonoFunctionAccessor

constructor(function: KFunction<*>)

Properties

function

open override val function: KFunction<*>

the synchronous Kotlin function to be invoked

method

open val method: Method

The underlying Java Method object for this function. This method is guaranteed to be non-null for accessible functions.

name

open override val name: String

The name of the function, inherited from the Named interface. Returns the simple name of the underlying Kotlin function.

targetType

open val targetType: Class<T>

The Java Class representing the type of the target object. This is derived from the declaring class of the function.

Functions

invoke

open operator override fun invoke(target: T, args: Array<Any?>): Mono<D>

Invokes the synchronous function and wraps the result in a Mono. Uses Mono.fromCallable to execute the blocking operation on a suitable thread and provide reactive stream compatibility.