Uses of Class
com.fluxtion.compiler.builder.stream.IntStreamBuilder

Packages that use IntStreamBuilder

Package	Description
com.fluxtion.compiler.builder.stream

Uses of IntStreamBuilder in com.fluxtion.compiler.builder.stream

Methods in com.fluxtion.compiler.builder.stream that return IntStreamBuilder

Modifier and Type	Method and Description
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder	IntStreamBuilder.aggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction)
IntStreamBuilder	IntStreamBuilder.console()
IntStreamBuilder	IntStreamBuilder.console(String in)
IntStreamBuilder	IntStreamBuilder.defaultValue(int defaultValue)
<S> IntStreamBuilder	IntStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntPredicate predicate, IntStreamBuilder secondArgument)
IntStreamBuilder	IntStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntFunction<Boolean> filterFunction)
IntStreamBuilder	IntStreamBuilder.id(String nodeId)
IntStreamBuilder	IntStreamBuilder.map(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntUnaryOperator int2IntFunction)
IntStreamBuilder	IntStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntFunction int2IntFunction, IntStreamBuilder stream2Builder)
IntStreamBuilder	DoubleStreamBuilder.mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableDoubleToIntFunction int2IntFunction)
IntStreamBuilder	LongStreamBuilder.mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableLongToIntFunction int2IntFunction)
IntStreamBuilder	EventStreamBuilder.mapToInt(com.fluxtion.runtime.partition.LambdaReflection.SerializableToIntFunction<T> mapFunction)
IntStreamBuilder	IntStreamBuilder.notify(Object target)
IntStreamBuilder	IntStreamBuilder.peek(com.fluxtion.runtime.partition.LambdaReflection.SerializableConsumer<Integer> peekFunction)
IntStreamBuilder	IntStreamBuilder.publishTrigger(Object publishTrigger)
IntStreamBuilder	IntStreamBuilder.publishTriggerOverride(Object publishTrigger)
IntStreamBuilder	IntStreamBuilder.push(com.fluxtion.runtime.partition.LambdaReflection.SerializableIntConsumer pushFunction)
IntStreamBuilder	IntStreamBuilder.resetTrigger(Object resetTrigger)
IntStreamBuilder	IntStreamBuilder.sink(String sinkId)
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder	IntStreamBuilder.slidingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis, int numberOfBuckets)
static IntStreamBuilder	EventFlow.subscribeToIntSignal(String filterId)
static IntStreamBuilder	EventFlow.subscribeToIntSignal(String filterId, int defaultValue)
<F extends com.fluxtion.runtime.stream.aggregate.IntAggregateFunction<F>> IntStreamBuilder	IntStreamBuilder.tumblingAggregate(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<F> aggregateFunction, int bucketSizeMillis)
IntStreamBuilder	IntStreamBuilder.updateTrigger(Object updateTrigger)

Methods in com.fluxtion.compiler.builder.stream with parameters of type IntStreamBuilder

Modifier and Type	Method and Description
<S> EventStreamBuilder<T>	EventStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<T,Integer,Boolean> predicate, IntStreamBuilder secondArgument)
<S> IntStreamBuilder	IntStreamBuilder.filter(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntPredicate predicate, IntStreamBuilder secondArgument)
<P,S> EventStreamBuilder<T>	EventStreamBuilder.filterByProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiFunction<P,Integer,Boolean> predicate, com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,P> accessor, IntStreamBuilder secondArgument)
IntStreamBuilder	IntStreamBuilder.mapBiFunction(com.fluxtion.runtime.partition.LambdaReflection.SerializableBiIntFunction int2IntFunction, IntStreamBuilder stream2Builder)