diff --git a/jetty-websocket/websocket-common/src/test/java/org/eclipse/jetty/websocket/common/SaneFrameOrderingAssertion.java b/jetty-websocket/websocket-common/src/test/java/org/eclipse/jetty/websocket/common/SaneFrameOrderingAssertion.java index b8aeb16dfd6..2140d234c99 100644 --- a/jetty-websocket/websocket-common/src/test/java/org/eclipse/jetty/websocket/common/SaneFrameOrderingAssertion.java +++ b/jetty-websocket/websocket-common/src/test/java/org/eclipse/jetty/websocket/common/SaneFrameOrderingAssertion.java @@ -34,6 +34,7 @@ import org.eclipse.jetty.websocket.api.extensions.OutgoingFrames; public class SaneFrameOrderingAssertion implements OutgoingFrames { boolean priorDataFrame = false; + public int frameCount = 0; @Override public void outgoingFrame(Frame frame, WriteCallback callback, BatchMode batchMode) @@ -63,11 +64,13 @@ public class SaneFrameOrderingAssertion implements OutgoingFrames break; } - if (OpCode.isDataFrame(frame.getOpCode())) + if (OpCode.isDataFrame(opcode)) { priorDataFrame = !frame.isFin(); } + frameCount++; + if (callback != null) callback.writeSuccess(); }