com.fluxtion.compiler.builder.stream

Class MergeMapStreamBuilder<T>

java.lang.Object

com.fluxtion.compiler.builder.stream.MergeMapStreamBuilder<T>

public class MergeMapStreamBuilder<T>
extends Object

Method Summary

Modifier and Type	Method and Description
com.fluxtion.runtime.stream.MergeMapEventStream<T>	build()
static <T> MergeMapStreamBuilder<T>	of(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<T> resultFactory)
<R> MergeMapStreamBuilder<T>	required(EventStreamBuilder<R> trigger, com.fluxtion.runtime.partition.LambdaReflection.SerializableBiConsumer<T,R> setValue)
<R> MergeMapStreamBuilder<T>	requiredNoTrigger(EventStreamBuilder<R> trigger, com.fluxtion.runtime.partition.LambdaReflection.SerializableBiConsumer<T,R> setValue)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

of

public static <T> MergeMapStreamBuilder<T> of(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<T> resultFactory)

required

public <R> MergeMapStreamBuilder<T> required(EventStreamBuilder<R> trigger,
                                             com.fluxtion.runtime.partition.LambdaReflection.SerializableBiConsumer<T,R> setValue)

requiredNoTrigger

public <R> MergeMapStreamBuilder<T> requiredNoTrigger(EventStreamBuilder<R> trigger,
                                                      com.fluxtion.runtime.partition.LambdaReflection.SerializableBiConsumer<T,R> setValue)

build

public com.fluxtion.runtime.stream.MergeMapEventStream<T> build()