com.fluxtion.compiler.builder.stream

Interface EventFlow

public interface EventFlow

Helper methods for subscribing and creating an EventStreamBuilder from external events or internal nodes in the graph.

Method Summary

Modifier and Type	Method and Description
static <T> EventStreamBuilder<T>	mergeMap(MergeMapStreamBuilder<T> builder) Merges and maps several EventStream's into a single event stream of type T
static <T> EventStreamBuilder<T>	subscribe(Class<T> classSubscription) Subscribes to events of type <T>.
static <T extends com.fluxtion.runtime.event.Event> EventStreamBuilder<T>	subscribe(Class<T> classSubscription, int filter) Subscribes to events of type <T> filtering by Event.filterId().
static <T extends com.fluxtion.runtime.event.Event> EventStreamBuilder<T>	subscribe(Class<T> classSubscription, String filter) Subscribes to events of type <T> filtering by Event.filterString().
static DoubleStreamBuilder	subscribeToDoubleSignal(String filterId)
static DoubleStreamBuilder	subscribeToDoubleSignal(String filterId, double defaultValue)
static IntStreamBuilder	subscribeToIntSignal(String filterId)
static IntStreamBuilder	subscribeToIntSignal(String filterId, int defaultValue)
static LongStreamBuilder	subscribeToLongSignal(String filterId)
static LongStreamBuilder	subscribeToLongSignal(String filterId, long defaultValue)
static <T> EventStreamBuilder<T>	subscribeToNode(T source) Subscribes to an internal node within the processing graph and presents it as an EventStreamBuilder for constructing stream processing logic.
static <T,R> EventStreamBuilder<R>	subscribeToNodeProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> sourceProperty)
static <R> EventStreamBuilder<R>	subscribeToNodeProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<R> propertySupplier)
static EventStreamBuilder<Object>	subscribeToSignal(String filterId)
static <T> EventStreamBuilder<T>	subscribeToSignal(String filterId, Class<T> signalType)
static <T> EventStreamBuilder<T>	subscribeToSignal(String filterId, Class<T> signalType, T defaultValue)

Method Detail

subscribe

static <T> EventStreamBuilder<T> subscribe(Class<T> classSubscription)

Subscribes to events of type <T>. Creates a handler method in the generated StaticEventProcessor so that if StaticEventProcessor.onEvent(Object) is called an invocation is routed to this EventStream

Type Parameters:

T - The actual type dispatched to this EventStream by the generated StaticEventProcessor

Parameters:

classSubscription - A class literal describing the subscription

Returns:

An EventStreamBuilder that can used to construct stream processing logic

subscribe

static <T extends com.fluxtion.runtime.event.Event> EventStreamBuilder<T> subscribe(Class<T> classSubscription,
                                                                                    String filter)

Subscribes to events of type <T> filtering by Event.filterString(). Creates a handler method in the generated StaticEventProcessor so that if StaticEventProcessor.onEvent(Object) is called an invocation is routed to this EventStream

Type Parameters:

T - The actual type dispatched to this EventStream by the generated StaticEventProcessor

Parameters:

classSubscription - A class literal describing the subscription

filter - The filter string to apply

Returns:

An EventStreamBuilder that can used to construct stream processing logic

subscribe

static <T extends com.fluxtion.runtime.event.Event> EventStreamBuilder<T> subscribe(Class<T> classSubscription,
                                                                                    int filter)

Subscribes to events of type <T> filtering by Event.filterId(). Creates a handler method in the generated StaticEventProcessor so that if StaticEventProcessor.onEvent(Object) is called an invocation is routed to this EventStream

Type Parameters:

T - The actual type dispatched to this EventStream by the generated StaticEventProcessor

Parameters:

classSubscription - A class literal describing the subscription

filter - The filter int to apply

Returns:

An EventStreamBuilder that can used to construct stream processing logic

subscribeToSignal

static EventStreamBuilder<Object> subscribeToSignal(String filterId)

subscribeToSignal

static <T> EventStreamBuilder<T> subscribeToSignal(String filterId,
                                                   Class<T> signalType)

subscribeToSignal

static <T> EventStreamBuilder<T> subscribeToSignal(String filterId,
                                                   Class<T> signalType,
                                                   T defaultValue)

subscribeToIntSignal

static IntStreamBuilder subscribeToIntSignal(String filterId)

subscribeToIntSignal

static IntStreamBuilder subscribeToIntSignal(String filterId,
                                             int defaultValue)

subscribeToDoubleSignal

static DoubleStreamBuilder subscribeToDoubleSignal(String filterId)

subscribeToDoubleSignal

static DoubleStreamBuilder subscribeToDoubleSignal(String filterId,
                                                   double defaultValue)

subscribeToLongSignal

static LongStreamBuilder subscribeToLongSignal(String filterId)

subscribeToLongSignal

static LongStreamBuilder subscribeToLongSignal(String filterId,
                                               long defaultValue)

subscribeToNode

static <T> EventStreamBuilder<T> subscribeToNode(T source)

Subscribes to an internal node within the processing graph and presents it as an EventStreamBuilder for constructing stream processing logic.

Type Parameters:

T - The type of the node

Parameters:

source - The node to be wrapped and made head of this stream

Returns:

An EventStreamBuilder that can used to construct stream processing logic

subscribeToNodeProperty

static <T,R> EventStreamBuilder<R> subscribeToNodeProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableFunction<T,R> sourceProperty)

subscribeToNodeProperty

static <R> EventStreamBuilder<R> subscribeToNodeProperty(com.fluxtion.runtime.partition.LambdaReflection.SerializableSupplier<R> propertySupplier)

mergeMap

static <T> EventStreamBuilder<T> mergeMap(MergeMapStreamBuilder<T> builder)

Merges and maps several EventStream's into a single event stream of type T

Type Parameters:

T - The output type of the merged stream

Parameters:

builder - The builder defining the merge operations

Returns:

An EventStreamBuilder that can used to construct stream processing logic