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

PublisherMonoFunctionAccessor

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

MonoFunctionAccessor for functions that return Publisher streams. This accessor converts Publisher results to a Mono that contains all emitted items as a List.

Parameters

function

the Kotlin function that returns a Publisher

Type Parameters

the type of the target object

the type of data in the Publisher

Constructors

PublisherMonoFunctionAccessor

constructor(function: KFunction<*>)

Functions

invoke

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

Invokes the function that returns a Publisher and converts it to a Mono. Uses Mono.defer for lazy evaluation and collectList() to aggregate the Publisher emissions.

invoke1

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