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

FluxMonoFunctionAccessor

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

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.

Parameters

function

the Kotlin function that returns a Flux

Type Parameters

the type of the target object

the type of individual items in the Flux

Constructors

FluxMonoFunctionAccessor

constructor(function: KFunction<*>)

Functions

invoke

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

Invokes the function that returns a Flux and collects all emitted items into a List. Uses Mono.defer for lazy evaluation and collectList() to aggregate the Flux emissions.

invoke1

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