modelql-core/org.modelix.modelql.core/FluxUnboundQuery

FluxUnboundQuery

class FluxUnboundQuery<In, ElementOut>(inputStep: QueryInput<In>, outputStep: IFluxStep<ElementOut>, reference: QueryReference<*>, sharedSteps: List<SharedStep<*>>) : UnboundQuery<In, List<IStepOutput<ElementOut>>, ElementOut> , IFluxUnboundQuery<In, ElementOut>

Constructors

FluxUnboundQuery

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

Properties

val inputStep: QueryInput<In>

open override val outputStep: IFluxStep<ElementOut>

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

val sharedSteps: List<SharedStep<*>>

Functions

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

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

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

open override 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>

createDescriptor

fun createDescriptor(): QueryGraphDescriptor

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

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

getAggregationOutputSerializer

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

fun getAllSteps(): Set<IStep>

getElementOutputSerializer

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

fun getOwnSteps(): List<IStep>

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

requiresWriteAccess

open override fun requiresWriteAccess(): Boolean

open override fun toString(): String