Closed jhermsmeier closed 7 years ago
Due to an error in how blocks were chunked, it was possible to emit too small or improperly sized blocks when encountering backpressure buffering.
This fixes that behavior, and ensures that all read buffers are consumed.
I added some comments about potential edge cases (ignore me if I'm missing something), but otherwise it looks great, and the tests pass :+1:
Due to an error in how blocks were chunked, it was possible to emit too small or improperly sized blocks when encountering backpressure buffering.
This fixes that behavior, and ensures that all read buffers are consumed.