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

Package-level declarations

Types

BlockingMonoFunctionAccessor

class BlockingMonoFunctionAccessor<T, D>(monoFunctionAccessor: MonoFunctionAccessor<T, Mono<D>>, scheduler: Scheduler = Schedulers.boundedElastic()) : MonoFunctionAccessor<T, Mono<D>>

FluxMonoFunctionAccessor

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

MonoFunctionAccessor

interface MonoFunctionAccessor<T, out R : Mono<*>> : ReactiveFunctionAccessor<T, R>

MonoMethodAccessorFactory

object MonoMethodAccessorFactory

PublisherMonoFunctionAccessor

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

ReactiveFunctionAccessor

interface ReactiveFunctionAccessor<T, out R : Publisher<*>> : FunctionAccessor<T, R>

SimpleMonoFunctionAccessor

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

SyncMonoFunctionAccessor

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

Functions

fun <T> Mono<T>.toBlockable(scheduler: Scheduler = Schedulers.boundedElastic()): Mono<T>

toMonoFunctionAccessor

fun <T, D> KFunction<*>.toMonoFunctionAccessor(): MonoFunctionAccessor<T, Mono<D>>