Module swim.streamlet

Package 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.

Related Packages

Package	Description
swim.streamlet.combinator	Stateful streaming operators and combinators.
swim.streamlet.function	Stateful streaming combinator function interfaces.

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>
GenericStreamlet<I,O>
In
Inlet<I>	Input connector into a Streamlet.
Inout
Inoutlet<I,O>
KeyEffect
KeyOutlet<K,V>
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>
MapInput<K,V>
MapOutlet<K,V,O>	Output connector from a Streamlet for a key-value map state.
MapOutput<K,V>
Out
Outlet<O>	Output connector from a Streamlet.
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.
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.
StreamletException
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.
StreamletScope<O>
ValueInput<O>
ValueOutput<I>