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

PublisherMonoFunctionAccessor

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

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.

Parameters

the type of the target object

the type of data in the Publisher

Constructors

PublisherMonoFunctionAccessor

constructor(function: KFunction<*>)

Properties

function

open override val function: KFunction<*>

The Kotlin reflection KFunction representing this function. Provides access to Kotlin-specific metadata and reflection capabilities.

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 function that returns a Publisher and converts it to a Mono. Uses Mono.defer for lazy evaluation and toMono() to convert the Publisher to a Mono that emits the first item.