IFluxOrMonoStep

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<E>)
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 fun canBeEmpty(): Boolean
Link copied to clipboard
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
Link copied to clipboard
fun <T> IFluxStep<T>.drop(count: Int): IFluxStep<T>
Link copied to clipboard
open fun evaluateStatically(): E
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<E>>
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
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
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 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>>