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

SimpleMonoFunctionAccessor

class SimpleMonoFunctionAccessor<T, D : Any>(function: KFunction<*>) : AbstractMonoFunctionAccessor<T, Mono<D>>

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.

Parameters

function

the Kotlin function that returns a Mono

Type Parameters

the type of the target object

the type of data in the Mono

Constructors

SimpleMonoFunctionAccessor

constructor(function: KFunction<*>)

Functions

invoke

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

Invokes the function and returns its Mono result, wrapped in Mono.defer for proper lazy evaluation. The defer operator ensures that the function is only executed when the Mono is subscribed to.

invoke1

open override fun invoke1(target: T, arg: Any?): Mono<D>