Composable primitives for asynchronous data flows.
Factory functions that open a feed over values and data sources.
Intermediate operations that transform, filter or reshape the items of a feed.
Terminal operations that consume the items of a feed and compute the final result.
Composable primitives for asynchronous data flows.