OOM using bufferSliding

[jsfwa]

ZIO version: 1.0.0-RC21

Hi guys, simple reproducible OOM via bufferSliding:

 ZStream
      .repeat(Foo(1L))
      .bufferSliding(1)
      .runDrain
      .exitCode

[iravid]

Thank you for reporting (and minimizing!) @jsfwa. We'll look into this.

[jsfwa]

Just checked, the leak is in this recursive call https://github.com/zio/zio/blob/master/streams/shared/src/main/scala/zio/stream/ZStream.scala#L434
changed it to

Take.fromPull(as).tap(take => queue.offer(take)).doWhile(_ != Take.end).unit

And looks like it solved the problem, but not sure about the correctness of this approach

[iravid]

@jsfwa Interesting. Would you like to open a PR with the fix and we can verify it there?

[narma]

Hey! I'm @jsfwa colleague, and he asked me to create PR because he away from the computer for a weekend.