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 decoheres a parameterized Outlet whenever the Inlet decoheres, and that recoheres the parameterized Outlet whenever the Inlet recoheres.
OutletMapInlet<K,V,O>	A MapInlet that decoheres a parameterized Outlet whenever the MapInlet decoheres, and that recoheres the parameterized Outlet whenever the MapInlet recoheres.
StreamletInlet<I>	An Inlet that decoheres a parameterized Streamlet whenever the Inlet decoheres, and that recoheres the parameterized Streamlet whenever the Inlet recoheres.
StreamletInoutlet<I,O>	An Inoutlet that decoheres a parameterized Streamlet whenever the Inoutlet decoheres, that recoheres the parameterized Streamlet whenever the Inoutlet recoheres, and which gets its state from the parameterized Streamlet.
StreamletOutlet<O>	An Outlet that decoheres a parameterized Streamlet whenever the Outlet decoheres, 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