StreamReader

[VictorGaiva]

StreamReader

Motivation

After a system has been running for a while, we might want to manually read all of its messages to transform the data in some way. For example:

• Creating a Livebook Chart with information about the amount of events of each type in a single Stream
• Transform the data from multiple streams into a single new stream

Proposal

Implement a 'StreamReader' module that provides an API for reading all the messages from a Stream. It should provide an API for using it as a Elixir's Stream, allowing it to be connected with other features, such as Flow and GenStage.