reader-soup
approach, because when I did it polysemy wasn't known yet)
transient
again here. However, it's currently rough in terms of developer UX and the materials are not super accessible. (It's basically ContT
over IO
with semantics similar to ListT
. However, composing all the streaming in a distributed setting is never trivial.) The best source of current information is probably via the author in the gitter: https://gitter.im/Transient-Transient-Universe-HPlay/Lobby. I know he's working on a new release.
PTask
? Say my PTask
is a foldM
and I need to stream all the source files? Similarly, if the output files from the PTask
are (effectfully) written at intervals from the fold, is there a reasonable way to interface with a datasink?
streamly
to do the concurrent transformations, is there a recommended way to purely pass those to a datasink or do I need to setup a fifo queue in STM
?