Skip to content

Commit d375e37

Browse files
pimterryjasnellEthan-Arrowood
authored
Apply suggestions from code review
Co-authored-by: James M Snell <jasnell@gmail.com> Co-authored-by: Ethan Arrowood <ethan@arrowood.dev>
1 parent 7af487d commit d375e37

2 files changed

Lines changed: 1 addition & 3 deletions

File tree

src/quic/streams.cc

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1512,7 +1512,6 @@ void Stream::EndWriting() {
15121512
void Stream::EntryRead(size_t amount) {
15131513
// Called when the JS consumer reads data from the inbound DataQueue.
15141514
// Extend the flow control window so the sender can transmit more.
1515-
//
15161515
if (session().is_destroyed()) return;
15171516
Session::SendPendingDataScope send_scope(&session());
15181517
session().ExtendStreamOffset(id(), amount);

test/parallel/test-quic-stream-read-after-blocked.mjs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,5 @@ await stream.closed;
5858
clientSession.close();
5959
done.resolve();
6060

61-
await done.promise;
62-
await clientSession.closed;
61+
await Promise.all([done.promise, clientSession.closed]);
6362
await serverEndpoint.close();

0 commit comments

Comments
 (0)