modelql-core/org.modelix.modelql.core/MonoUnboundQuery

MonoUnboundQuery

class MonoUnboundQuery<In, ElementOut>(inputStep: QueryInput<In>, outputStep: IMonoStep<ElementOut>, reference: QueryReference<*>, sharedSteps: List<SharedStep<*>>) : UnboundQuery<In, ElementOut, ElementOut> , IMonoUnboundQuery<In, ElementOut>

Constructors

MonoUnboundQuery

constructor(inputStep: QueryInput<In>, outputStep: IMonoStep<ElementOut>, reference: QueryReference<*>, sharedSteps: List<SharedStep<*>>)

Properties

inputStep

val inputStep: QueryInput<In>

outputStep

open override val outputStep: IMonoStep<ElementOut>

reference

open override val reference: QueryReference<UnboundQuery<In, ElementOut, ElementOut>>

sharedSteps

val sharedSteps: List<SharedStep<*>>

Functions

asFlow

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

open override fun asFlow(evaluationContext: QueryEvaluationContext, input: StepFlow<In>): StepFlow<ElementOut>

bind

open override fun bind(executor: IQueryExecutor<In>): IMonoQuery<ElementOut>

canBeEmpty

open override fun canBeEmpty(): Boolean

castToInstance

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

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

createDescriptor

fun createDescriptor(): QueryGraphDescriptor

evaluate

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

execute

open suspend override fun execute(evaluationContext: QueryEvaluationContext, input: IStepOutput<In>): IStepOutput<ElementOut>

flatMap

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

getAggregationOutputSerializer

open override fun getAggregationOutputSerializer(serializationContext: SerializationContext): KSerializer<IStepOutput<ElementOut>>

getAllSteps

fun getAllSteps(): Set<IStep>

getElementOutputSerializer

open override fun getElementOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<ElementOut>>

getOwnSteps

fun getOwnSteps(): List<IStep>

map

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

open override fun <T> map(query: IFluxUnboundQuery<ElementOut, T>): IFluxUnboundQuery<In, T>

open override fun <T> map(query: IMonoUnboundQuery<ElementOut, T>): IMonoUnboundQuery<In, T>

map

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

requiresWriteAccess

open override fun requiresWriteAccess(): Boolean

toString

open override fun toString(): String

validate

fun validate()