diff --git a/src/main/java/core/packetproxy/http2/FlowControlManager.java b/src/main/java/core/packetproxy/http2/FlowControlManager.java index 931368e..3564be5 100644 --- a/src/main/java/core/packetproxy/http2/FlowControlManager.java +++ b/src/main/java/core/packetproxy/http2/FlowControlManager.java @@ -100,12 +100,14 @@ public void write(Frame frame) throws Exception { if (frame.getType() == Frame.Type.HEADERS) { /* TODO: maximum concurrent streams is not implemented yet */ outputForFlowControl.write(frame.toByteArray()); + outputForFlowControl.flush(); } else if (frame.getType() == Frame.Type.DATA) { FlowControl flow = getFlow(frame.getStreamId()); flow.enqueue(frame); writeData(flow); } else { outputForFlowControl.write(frame.toByteArray()); + outputForFlowControl.flush(); } }