diff --git a/lib/Cro/HTTP2/FrameParser.pm6 b/lib/Cro/HTTP2/FrameParser.pm6 index d3f1b36..f0f4a66 100644 --- a/lib/Cro/HTTP2/FrameParser.pm6 +++ b/lib/Cro/HTTP2/FrameParser.pm6 @@ -64,7 +64,16 @@ class Cro::HTTP2::FrameParser does Cro::Transform does Cro::ConnectionState[Cro: stream-identifier => $sid, conn => $packet.connection); if $result ~~ Cro::HTTP2::Frame::Data { - unless $result.end-stream { + if $result.end-stream { + start { + my $bytes = $result.data.bytes; + $connection-state.window-size.emit: + Cro::HTTP2::Frame::WindowUpdate.new: + stream-identifier => 0, + flags => 0, increment => $bytes; + } + } + else { start { my $bytes = $result.data.bytes; $connection-state.window-size.emit: