Stream

The FlowStream module provides asynchronous, pull-based streams.

Core type

• FsFlow.FlowStream: Represents a cold stream of values that requires an environment, can fail with a typed error, and supports backpressure.

Module functions

• FsFlow.FlowStreamModule.fromSeq: Creates a stream from a sequence of values.
• FsFlow.FlowStreamModule.map: Maps the successful values of a stream.
• FsFlow.FlowStreamModule.runForEach: Executes the stream and performs an action for each value.