Based on this comment, I think what we might be missing is way to convert a concurrent stream back to a sequential one.
That should allow for staged composition with separate concurrency limits, where each stage preserves its own internal state — but externally it still just looks like what we would expect with sequences going in, sequences going out.
Based on this comment, I think what we might be missing is way to convert a concurrent stream back to a sequential one.
That should allow for staged composition with separate concurrency limits, where each stage preserves its own internal state — but externally it still just looks like what we would expect with sequences going in, sequences going out.