Home | History | Annotate | Download | only in elonen

Lines Matching defs:WebSocketFrame

51 import fi.iki.elonen.NanoWSD.WebSocketFrame.CloseCode;
52 import fi.iki.elonen.NanoWSD.WebSocketFrame.CloseFrame;
53 import fi.iki.elonen.NanoWSD.WebSocketFrame.OpCode;
71 private WebSocketFrame.OpCode continuousOpCode = null;
73 private final List<WebSocketFrame> continuousFrames = new LinkedList<WebSocketFrame>();
108 protected abstract void onMessage(WebSocketFrame message);
110 protected abstract void onPong(WebSocketFrame pong);
120 protected void debugFrameReceived(WebSocketFrame frame) {
130 protected void debugFrameSent(WebSocketFrame frame) {
175 private void handleCloseFrame(WebSocketFrame frame) throws IOException {
190 private void handleFrameFragment(WebSocketFrame frame) throws IOException {
204 onMessage(new WebSocketFrame(this.continuousOpCode, this.continuousFrames));
216 private void handleWebsocketFrame(WebSocketFrame frame) throws IOException {
221 sendFrame(new WebSocketFrame(OpCode.Pong, true, frame.getBinaryPayload()));
238 sendFrame(new WebSocketFrame(OpCode.Ping, true, payload));
247 handleWebsocketFrame(WebSocketFrame.read(this.in));
263 sendFrame(new WebSocketFrame(OpCode.Binary, true, payload));
267 sendFrame(new WebSocketFrame(OpCode.Text, true, payload));
270 public synchronized void sendFrame(WebSocketFrame frame) throws IOException {
307 public static class WebSocketFrame {
343 public static class CloseFrame extends WebSocketFrame {
366 private CloseFrame(WebSocketFrame wrap) throws CharacterCodingException {
419 return new String(payload, WebSocketFrame.TEXT_CHARSET);
423 return new String(payload, offset, length, WebSocketFrame.TEXT_CHARSET);
433 public static WebSocketFrame read(InputStream in) throws IOException {
446 WebSocketFrame frame = new WebSocketFrame(opCode, fin);
457 return payload.getBytes(WebSocketFrame.TEXT_CHARSET);
474 private WebSocketFrame(OpCode opCode, boolean fin) {
479 public WebSocketFrame(OpCode opCode, boolean fin, byte[] payload) {
483 public WebSocketFrame(OpCode opCode, boolean fin, byte[] payload, byte[] maskingKey) {
489 public WebSocketFrame(OpCode opCode, boolean fin, String payload) throws CharacterCodingException {
493 public WebSocketFrame(OpCode opCode, boolean fin, String payload, byte[] maskingKey) throws CharacterCodingException {
499 public WebSocketFrame(OpCode opCode, List<WebSocketFrame> fragments) throws WebSocketException {
504 for (WebSocketFrame inter : fragments) {
513 for (WebSocketFrame inter : fragments) {
520 public WebSocketFrame(WebSocketFrame clone) {