Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
val <T> IMonoStep<IZip8Output<*, *, *, *, *, *, *, *, T>>.eighth: IMonoStep<T>
Link copied to clipboard
val <T> IMonoStep<IZip5Output<*, *, *, *, *, T>>.fifth: IMonoStep<T>
Link copied to clipboard
Link copied to clipboard
val <T> IMonoStep<IZip4Output<*, *, *, *, T>>.forth: IMonoStep<T>
Link copied to clipboard
val <T> IMonoStep<IZip4Output<*, *, *, *, T>>.fourth: IMonoStep<T>
Link copied to clipboard
Link copied to clipboard
val <T> IMonoStep<IZip9Output<*, *, *, *, *, *, *, *, *, T>>.ninth: IMonoStep<T>
Link copied to clipboard
abstract val owner: QueryReference<*>
Link copied to clipboard
Link copied to clipboard
val <T> IMonoStep<IZip7Output<*, *, *, *, *, *, *, T>>.seventh: IMonoStep<T>
Link copied to clipboard
val <T> IMonoStep<IZip6Output<*, *, *, *, *, *, T>>.sixth: IMonoStep<T>
Link copied to clipboard
val <T> IMonoStep<IZip3Output<*, *, *, T>>.third: IMonoStep<T>
Link copied to clipboard

Functions

Link copied to clipboard
abstract fun addConsumer(consumer: IConsumingStep<Out>)
Link copied to clipboard
open override fun addProducer(producer: IProducingStep<In>)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <In, K, V> IFluxStep<In>.associate(keySelector: (IMonoStep<In>) -> IMonoStep<K>, valueSelector: (IMonoStep<In>) -> IMonoStep<V>): IMonoStep<Map<K, V>>
Link copied to clipboard
fun <K, V> IFluxStep<V>.associateBy(keySelector: (IMonoStep<V>) -> IMonoStep<K>): IMonoStep<Map<K, V>>
Link copied to clipboard
fun <K, V> IFluxStep<K>.associateWith(valueSelector: (IMonoStep<K>) -> IMonoStep<V>): IMonoStep<Map<K, V>>
Link copied to clipboard
@JvmName(name = "asStringNullable")
fun IFluxStep<Any?>.asString(): IFluxStep<String?>
@JvmName(name = "asStringNullable")
fun IMonoStep<Any?>.asString(): IMonoStep<String?>
Link copied to clipboard
open override fun canBeEmpty(): Boolean
Link copied to clipboard
open override fun canBeMultiple(): Boolean
Link copied to clipboard
Link copied to clipboard
operator fun <T> IMonoStep<IZip1Output<*, T>>.component1(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip2Output<*, *, T>>.component2(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip3Output<*, *, *, T>>.component3(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip4Output<*, *, *, *, T>>.component4(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip5Output<*, *, *, *, *, T>>.component5(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip6Output<*, *, *, *, *, *, T>>.component6(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip7Output<*, *, *, *, *, *, *, T>>.component7(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip8Output<*, *, *, *, *, *, *, *, T>>.component8(): IMonoStep<T>
Link copied to clipboard
operator fun <T> IMonoStep<IZip9Output<*, *, *, *, *, *, *, *, *, T>>.component9(): IMonoStep<T>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun createFlow(context: IFlowInstantiationContext): StepFlow<Out>
Link copied to clipboard
fun <T> IFluxStep<T>.drop(count: Int): IFluxStep<T>
Link copied to clipboard
Link copied to clipboard
fun <In, Out> IFluxStep<In>.executeLocal(body: (In) -> Out): IFluxStep<Out>
fun <In, Out> IMonoStep<In>.executeLocal(body: (In) -> Out): IMonoStep<Out>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
operator fun <K, V> IMonoStep<Map<K, V>>.get(operand: IMonoStep<K>): IMonoStep<V?>
Link copied to clipboard
abstract fun getConsumers(): List<IConsumingStep<*>>
Link copied to clipboard
abstract fun getOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<Out>>
Link copied to clipboard
Link copied to clipboard
open override fun getProducers(): List<IProducingStep<In>>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "ifEmpty_flux_mono")
fun <In : Out, Out> IFluxStep<In>.ifEmpty(alternative: () -> IMonoStep<Out>): IFluxStep<Out>
@JvmName(name = "ifEmpty_mono_mono")
fun <In : Out, Out> IMonoStep<In>.ifEmpty(alternative: () -> IMonoStep<Out>): IMonoStep<Out>
Link copied to clipboard
@JvmName(name = "ifEmpty_flux_flux")
fun <In : Out, Out> IFluxStep<In>.ifEmptyFlux(alternative: () -> IFluxStep<Out>): IFluxStep<Out>
@JvmName(name = "ifEmpty_mono_flux")
fun <In : Out, Out> IMonoStep<In>.ifEmptyFlux(alternative: () -> IFluxStep<Out>): IFluxStep<Out>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <In, Out> IFluxStep<In>.mapLocal(body: (In) -> Out): IFluxStep<Out>
fun <In, Out> IMonoStep<In>.mapLocal(body: (In) -> Out): IMonoStep<Out>
Link copied to clipboard
Link copied to clipboard
open override fun needsCoroutineScope(): Boolean
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
operator fun IFluxStep<Int>.plus(other: Int): IFluxStep<Int>
operator fun IMonoStep<Int>.plus(other: Int): IMonoStep<Int>
Link copied to clipboard
fun <T> IFluxStep<T>.print(prefix: String = ""): IFluxStep<T>
fun <T> IMonoStep<T>.print(prefix: String = ""): IMonoStep<T>
Link copied to clipboard
open override fun requiresSingularQueryInput(): Boolean
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <T> IFluxStep<T>.take(count: Int): IFluxStep<T>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <K, V> IFluxStep<IZip2Output<*, K, V>>.toMap(): IMonoStep<Map<K, V>>
Link copied to clipboard
Link copied to clipboard

Sometimes you need an additional wrapper list, but to avoid this being done accidentally it has a different name.

Link copied to clipboard
Link copied to clipboard
open override fun validate()
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <T> IMonoStep<T>.zip(vararg others: IMonoStep<T>): IMonoStep<IZipOutput<T>>
fun <Common, T1 : Common, T2 : Common, T3 : Common, T4 : Common> IMonoStep<T1>.zip(other2: IMonoStep<T2>, other3: IMonoStep<T3>, other4: IMonoStep<T4>): IMonoStep<IZip4Output<Common, T1, T2, T3, T4>>
fun <Common, T1 : Common, T2 : Common, T3 : Common, T4 : Common, T5 : Common> IMonoStep<T1>.zip(other2: IMonoStep<T2>, other3: IMonoStep<T3>, other4: IMonoStep<T4>, other5: IMonoStep<T5>): IMonoStep<IZip5Output<Common, T1, T2, T3, T4, T5>>
Link copied to clipboard
fun <T> IMonoStep<T>.zipN(vararg others: IMonoStep<T>): IMonoStep<IZipOutput<T>>