• tubes - tubes offers an abstraction of data flow and backpressure for event-driven applications.
  • tubes._components - Various component utilities.
  • tubes._siphon - Adapters for converting ITube to IDrain and IFount.
  • tubes.fan - Tools for turning founts and drains into multiple founts and drains.
  • tubes.framing - Tubes that can convert streams of data into discrete chunks and back again.
  • tubes.itube - Interfaces related to data flows.
  • tubes.kit - Toolkit to alleviate some of the duplication in constructing your own IFount and IDrain implementations.
  • tubes.listening - Listening.
  • tubes.memory - Founts and drains that can produce values from static data in memory.
  • tubes.protocol - Objects to connect real data to tubes.
  • tubes.routing - A Router receives items with addressing information and dispatches them to an appropriate output, stripping the addressing information off.
  • tubes.tube - See tube.
  • tubes.undefer - Deferred support for Tubes.