Adapters.publisherToStream doesn't emit all messages

[brs-lphv]

ZIO
  .foreach((1 to 10000).toList)(_ =>
    Adapters
      .publisherToStream(new NumberIterablePublisher(0, 1, executor), 16)
      .runCount
  )
  .map(_.count(_ == 1)) // returns 9995

Version: 2.0.0

it looks like between read buffer and start await, subscriber receives message and complete signal.
In the await method, it sees that 'done' variable is defined and stops the stream, skipping received message