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.
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:
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 asFlowandGenStage.