modelql-core/org.modelix.modelql.core/IFluxUnboundQuery

IFluxUnboundQuery

interface IFluxUnboundQuery<in In, out Out> : IUnboundQuery<In, List<IStepOutput<Out>>, Out>

Inheritors

FluxUnboundQuery

Properties

abstract val reference: IQueryReference<IUnboundQuery<In, List<IStepOutput<Out>>, Out>>

Functions

abstract fun asFlow(evaluationContext: QueryEvaluationContext, input: StepFlow<In>): StepFlow<Out>

open fun asFlow(evaluationContext: QueryEvaluationContext, input: IStepOutput<In>): StepFlow<Out>

abstract override fun bind(executor: IQueryExecutor<In>): IFluxQuery<Out>

abstract fun canBeEmpty(): Boolean

fun <In, Out> IFluxUnboundQuery<In, Out>.castToInstance(): FluxUnboundQuery<In, Out>

fun <In, Out, ElementOut> IUnboundQuery<In, Out, ElementOut>.castToInstance(): UnboundQuery<In, Out, ElementOut>

abstract suspend fun execute(evaluationContext: QueryEvaluationContext, input: IStepOutput<In>): IStepOutput<List<IStepOutput<Out>>>

abstract fun <T> flatMap(body: (IMonoStep<Out>) -> IFluxStep<T>): IFluxUnboundQuery<In, T>

getAggregationOutputSerializer

abstract fun getAggregationOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<List<IStepOutput<Out>>>>

getElementOutputSerializer

abstract fun getElementOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<Out>>

abstract fun <T> map(body: (IMonoStep<Out>) -> IMonoStep<T>): IFluxUnboundQuery<In, T>

requiresWriteAccess

abstract fun requiresWriteAccess(): Boolean