Merge remote-tracking branch 'origin/jetty-10.0.x' into jetty-11.0.x
This commit is contained in:
commit
5727719bf0
|
@ -596,9 +596,10 @@ public class JakartaWebSocketFrameHandler implements FrameHandler
|
|||
}
|
||||
|
||||
// Accept the payload into the message sink
|
||||
activeMessageSink.accept(frame, callback);
|
||||
MessageSink messageSink = activeMessageSink;
|
||||
if (frame.isFin())
|
||||
activeMessageSink = null;
|
||||
messageSink.accept(frame, callback);
|
||||
}
|
||||
|
||||
public void onPing(Frame frame, Callback callback)
|
||||
|
|
|
@ -345,9 +345,10 @@ public class JettyWebSocketFrameHandler implements FrameHandler
|
|||
}
|
||||
|
||||
// Accept the payload into the message sink
|
||||
activeMessageSink.accept(frame, callback);
|
||||
MessageSink messageSink = activeMessageSink;
|
||||
if (frame.isFin())
|
||||
activeMessageSink = null;
|
||||
messageSink.accept(frame, callback);
|
||||
}
|
||||
|
||||
private void onBinaryFrame(Frame frame, Callback callback)
|
||||
|
|
Loading…
Reference in New Issue