ZipElementAccessStep

Constructors

Link copied to clipboard
constructor(index: Int)

Types

Link copied to clipboard
@Serializable
@SerialName(value = "zip.output.access")
class Descriptor(val index: Int) : CoreStepDescriptor

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
val index: Int
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<IZipOutput<Any?>>)
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
open override fun getOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<Out>>
Link copied to clipboard
Link copied to clipboard
open override fun getProducers(): List<IProducingStep<IZipOutput<Any?>>>
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
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
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 toString(): String
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>>