IFluxQuery

interface IFluxQuery<out Out> : IQuery<List<IStepOutput<Out>>, Out>

Functions

Link copied to clipboard
abstract suspend fun asFlow(): StepFlow<Out>
Link copied to clipboard
abstract suspend fun execute(): IStepOutput<List<IStepOutput<Out>>>
Link copied to clipboard
abstract fun <T> flatMap(body: (IMonoStep<Out>) -> IFluxStep<T>): IFluxQuery<T>
Link copied to clipboard
abstract fun <T> map(body: (IMonoStep<Out>) -> IMonoStep<T>): IFluxQuery<T>