reader-soupapproach, because when I did it polysemy wasn't known yet)
transientagain here. However, it's currently rough in terms of developer UX and the materials are not super accessible. (It's basically
IOwith 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
foldMand I need to stream all the source files? Similarly, if the output files from the
PTaskare (effectfully) written at intervals from the fold, is there a reasonable way to interface with a datasink?
streamlyto 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