modelql-core/org.modelix.modelql.core/ProducingStep

ProducingStep

abstract class ProducingStep<E> : IProducingStep<E>

Inheritors

Constructors

ProducingStep

constructor()

Properties

owner

open override val owner: QueryReference<*>

Functions

addConsumer

open override fun addConsumer(consumer: IConsumingStep<E>)

canBeEmpty

open fun canBeEmpty(): Boolean

canBeMultiple

open fun canBeMultiple(): Boolean

canEvaluateStatically

open fun canEvaluateStatically(): Boolean

connect

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

createDescriptor

open fun createDescriptor(context: QueryGraphDescriptorBuilder): StepDescriptor

createFlow

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

evaluateStatically

open fun evaluateStatically(): E

first

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

firstOrNull

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

flatMap

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>

getConsumers

open override fun getConsumers(): List<IConsumingStep<E>>

getOutputSerializer

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

getRootInputSteps

open fun getRootInputSteps(): Set<IStep>

hasSideEffect

open fun hasSideEffect(): Boolean

isEmpty

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

isNotEmpty

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

isSingle

fun IProducingStep<*>.isSingle(): Boolean

needsCoroutineScope

open fun needsCoroutineScope(): Boolean

outputIsConsumedMultipleTimes

open fun outputIsConsumedMultipleTimes(): Boolean

plus

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

requiresSingularQueryInput

open override fun requiresSingularQueryInput(): Boolean

requiresWriteAccess

open fun requiresWriteAccess(): Boolean

validate

open fun validate()

zip

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

zipN

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