t.f.stage : module documentation

flow.stage

Various stages for manipulating data flows, in particular, those stages which take more than one input stages or alternative input, such as a callback.

Class	Map	flow equivalent to map: Map(function, stage, ... )
Class	Zip	Zips two or more stages into a stream of N tuples
Class	Concurrent	Executes stages concurrently
Class	Merge	Merges two or more Stages results into a single stream
Class	Callback	Converts a single-thread push interface into a pull interface.