modelql-core/org.modelix.modelql.core/IMonoUnboundQuery

IMonoUnboundQuery

interface IMonoUnboundQuery<in In, out Out> : IUnboundQuery<In, Out, Out>

Inheritors

MonoUnboundQuery

Properties

abstract val reference: IQueryReference<IUnboundQuery<In, 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>): IMonoQuery<Out>

abstract fun canBeEmpty(): Boolean

fun <In, Out> IMonoUnboundQuery<In, Out>.castToInstance(): MonoUnboundQuery<In, Out>

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

suspend fun <In, Out> IMonoUnboundQuery<In, Out>.evaluate(evaluationContext: QueryEvaluationContext, input: In): Optional<Out>

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

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

getAggregationOutputSerializer

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

getElementOutputSerializer

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

open fun <T> map(body: (IMonoStep<Out>) -> IMonoStep<T>): IMonoUnboundQuery<In, T>

abstract fun <T> map(query: IFluxUnboundQuery<Out, T>): IFluxUnboundQuery<In, T>

abstract fun <T> map(query: IMonoUnboundQuery<Out, T>): IMonoUnboundQuery<In, T>

fun <In, Out, AggregationT, T> IMonoUnboundQuery<In, Out>.map(query: IUnboundQuery<Out, AggregationT, T>): IUnboundQuery<In, AggregationT, T>

requiresWriteAccess

abstract fun requiresWriteAccess(): Boolean