modelql-core/org.modelix.modelql.core/IProcessingStep

IProcessingStep

interface IProcessingStep<In, Out> : IConsumingStep<In> , IProducingStep<Out>

Inheritors

TransformingStep

Properties

abstract val owner: QueryReference<*>

Functions

abstract fun addConsumer(consumer: IConsumingStep<Out>)

abstract fun addProducer(producer: IProducingStep<In>)

open fun canBeEmpty(): Boolean

open fun canBeMultiple(): Boolean

canEvaluateStatically

open fun canEvaluateStatically(): Boolean

fun <T> IConsumingStep<T>.connect(producer: IProducingStep<T>)

fun <T> IProducingStep<T>.connect(consumer: IConsumingStep<T>)

createDescriptor

open fun createDescriptor(context: QueryGraphDescriptorBuilder): StepDescriptor

abstract fun createFlow(context: IFlowInstantiationContext): StepFlow<Out>

evaluateStatically

open fun evaluateStatically(): Out

fun <Out> IProducingStep<Out>.first(): IMonoStep<Out>

fun <E> IProducingStep<E>.firstOrNull(): IMonoStep<E?>

fun <In, Out> IProducingStep<In>.flatMap(body: (IMonoStep<In>) -> IFluxStep<Out>): IFluxStep<Out>

fun <In, Out> IProducingStep<In>.flatMap(query: IFluxUnboundQuery<In, Out>): IFluxStep<Out>

abstract fun getConsumers(): List<IConsumingStep<*>>

getOutputSerializer

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

abstract fun getProducers(): List<IProducingStep<*>>

getRootInputSteps

open fun getRootInputSteps(): Set<IStep>

open fun hasSideEffect(): Boolean

inputIsConsumedMultipleTimes

open override fun inputIsConsumedMultipleTimes(): Boolean

fun IProducingStep<Any?>.isEmpty(): IMonoStep<Boolean>

fun IProducingStep<Any?>.isNotEmpty(): IMonoStep<Boolean>

fun IProducingStep<*>.isSingle(): Boolean

needsCoroutineScope

open fun needsCoroutineScope(): Boolean

outputIsConsumedMultipleTimes

open fun outputIsConsumedMultipleTimes(): Boolean

operator fun <Common> IProducingStep<Common>.plus(other: IProducingStep<Common>): IFluxStep<Common>

requiresSingularQueryInput

abstract fun requiresSingularQueryInput(): Boolean

requiresWriteAccess

open fun requiresWriteAccess(): Boolean

open fun validate()

fun <Common, T1 : Common, T2 : Common> IProducingStep<T1>.zip(other2: IProducingStep<T2>): IFluxStep<IZip2Output<Common, T1, T2>>

fun <T> IProducingStep<T>.zip(vararg others: IProducingStep<T>): IFluxStep<IZipOutput<T>>

fun <Common, T1 : Common, T2 : Common, T3 : Common> IProducingStep<T1>.zip(other2: IProducingStep<T2>, other3: IProducingStep<T3>): IFluxStep<IZip3Output<Common, T1, T2, T3>>

fun <Common, T1 : Common, T2 : Common, T3 : Common, T4 : Common> IProducingStep<T1>.zip(other2: IProducingStep<T2>, other3: IProducingStep<T3>, other4: IProducingStep<T4>): IFluxStep<IZip4Output<Common, T1, T2, T3, T4>>

fun <Common, T1 : Common, T2 : Common, T3 : Common, T4 : Common, T5 : Common> IProducingStep<T1>.zip(other2: IProducingStep<T2>, other3: IProducingStep<T3>, other4: IProducingStep<T4>, other5: IProducingStep<T5>): IFluxStep<IZip5Output<Common, T1, T2, T3, T4, T5>>

fun <T> IProducingStep<T>.zipN(vararg others: IProducingStep<T>): IFluxStep<IZipOutput<T>>