The function csv () is streaming!

You can encode as a stream.

You can decode as a stream.

But you can't transform as a stream. The inner call (csv (in => "a.csv, ...)) loads the entire file into memory.