Module swim.streamlet

Package swim.streamlet

Stateful, streaming component model for application componets that continuously consume input state from streaming inlets, and continuously produce output state on streaming outlets.

Interface Summary

Interface	Description
GenericStreamlet<I,O>
Inlet<I>	Input connector into a Streamlet.
Inoutlet<I,O>
MapInlet<K,V,I>	Input connector into a Streamlet for a key-value map state.
MapInletMapOutlet<KI,KO,VI,VO,I,O>
MapInletOutlet<K,V,I,O>
MapInoutlet<K,VI,VO,I,O>
MapOutlet<K,V,O>	Output connector from a Streamlet for a key-value map state.
Outlet<O>	Output connector from a Streamlet.
Streamlet<I,O>	Stateful node in a dataflow graph that uses the state of its Inlets to compute the state of its Outlets.
StreamletContext	Environment in which a Streamlet executes.
StreamletScope<O>

Class Summary

Class	Description
AbstractInlet<I>
AbstractInoutlet<I,O>
AbstractMapInlet<K,V,O>
AbstractMapInletMapOutlet<KI,KO,VI,VO,I,O>
AbstractMapInletOutlet<K,V,I,O>
AbstractMapInoutlet<K,VI,VO,I,O>
AbstractMapOutlet<K,V,O>
AbstractOutlet<O>
AbstractStreamlet<I,O>
KeyOutlet<K,V>
MapInput<K,V>
MapOutput<K,V>
OutletInlet<I>	An Inlet that invalidates a parameterized Outlet whenever the Inlet is invalidated, and that updates the parameterized Outlet whenever the Inlet updates.
OutletMapInlet<K,V,O>	A MapInlet that invalidates a parameterized Outlet whenever the MapInlet is invalidated, and that updates the parameterized Outlet whenever the MapInlet updates.
StreamletInlet<I>	An Inlet that invalidates a parameterized Streamlet whenever the Inlet is invalidated, and that updates the parameterized Streamlet whenever the Inlet updates.
StreamletInoutlet<I,O>	An Inoutlet that invalidates a parameterized Streamlet whenever the Inoutlet is invalidated, that updates the parameterized Streamlet whenever the Inoutlet updates, and which gets its state from the parameterized Streamlet.
StreamletOutlet<O>	An Outlet that invalidates a parameterized Streamlet whenever the Outlet is invalidated, and which gets its state from the parameterized Streamlet.
ValueInput<O>
ValueOutput<I>

Enum Summary

Enum	Description
KeyEffect

Exception Summary

Exception	Description
StreamletException

Annotation Types Summary

Annotation Type	Description
In
Inout
Out