StructuredIO, an Elixir API for consuming structured input streams

Yes. A GenStage can accumulate data and emit downstream a new format.

This would be a valuable addition to GenStage pipelines.

My thinking was that a Flow would be the high-level API for constructing GenStage networks. But that doesn’t actually appear to be the case.