Aff, Pipes and IAsyncEnumerable

[timmi-on-rails]

Motivation

I have a couple of Affs that I want to run in parallel with a windowSize to limit the degree of parallelism.
Furthermore, I'd like to have a Producer that yields the results in the order in which they finish.

Problem

My solution relies on Proxy.enumerate which expects IAsyncEnumerable.
I assume that this is the way to go, because of the samples and implementations I have sighted.

While I can live with my own solution, I'd appreciate support from the library.
Custom implementations can be error prone and not performant.

Idea

There is already utility such as TraverseParallel and SequenceParallel for sequences of Affs, which covers parallel execution and windowSizes.
However, these functions return an Aff that does not complete until every input Aff has completed.
So they are not useful when it comes to streaming the results.

I propose to add similar utility functions which return e.g. Eff<IAsyncEnumerable<Fin<T>>>, which is useful for streaming.
From a library perspective we should consider wrapping IAsyncEnumerable.

What do you think?