445                     ByteBuffer buffer = Utils.sliceWithLimitedCapacity(b, amount);

   445                     ByteBuffer buffer = Utils.sliceWithLimitedCapacity(b, amount);

   446                     pusher.onNext(List.of(buffer.asReadOnlyBuffer()));

   446                     pusher.onNext(List.of(buffer.asReadOnlyBuffer()));

   447                 }

   447                 }

   448                 if (unfulfilled == 0) {

   448                 if (unfulfilled == 0) {

   449                     // We're done! All data has been received.

   449                     // We're done! All data has been received.

   450                     assert closedExceptionally == null;

   451                     assert closedExceptionally == null;

   451                     onFinished.run();

   452                     onFinished.run();

   452                     pusher.onComplete();

   453                     pusher.onComplete();

   453                     completed = true;

   454                     completed = true;

   454                     onComplete.accept(closedExceptionally); // should be null

   455                     onComplete.accept(closedExceptionally); // should be null