com.caucho.remote.websocket
Class MaskedFrameInputStream
java.lang.Object
java.io.InputStream
com.caucho.remote.websocket.FrameInputStream
com.caucho.remote.websocket.MaskedFrameInputStream
- All Implemented Interfaces:
- WebSocketConstants, java.io.Closeable
public class MaskedFrameInputStream
- extends FrameInputStream
WebSocketInputStream reads a single WebSocket packet.
+-+------+---------+-+---------+
|F|xxx(3)|opcode(4)|R|len(7) |
+-+------+---------+-+---------+
OPCODES
0 - cont
1 - text
2 - binary
8 - close
Fields inherited from interface com.caucho.remote.websocket.WebSocketConstants |
CLOSE_ERROR, CLOSE_MESSAGE_TOO_BIG, CLOSE_OK, CLOSE_UTF8, FLAG_FIN, FLAG_MASK, MASK_OPCODE, OP_BINARY, OP_CLOSE, OP_CONT, OP_PING, OP_PONG, OP_TEXT, VERSION |
Methods inherited from class java.io.InputStream |
available, close, mark, markSupported, read, reset, skip |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MaskedFrameInputStream
public MaskedFrameInputStream()
init
public void init(WebSocketContext cxt,
java.io.InputStream is)
- Overrides:
init
in class FrameInputStream
getOpcode
public int getOpcode()
- Specified by:
getOpcode
in class FrameInputStream
isFinal
public boolean isFinal()
- Specified by:
isFinal
in class FrameInputStream
getLength
public long getLength()
- Specified by:
getLength
in class FrameInputStream
getMask
public final byte[] getMask()
read
public int read()
throws java.io.IOException
- Specified by:
read
in class java.io.InputStream
- Throws:
java.io.IOException
read
public int read(byte[] buffer,
int offset,
int length)
throws java.io.IOException
- Overrides:
read
in class java.io.InputStream
- Throws:
java.io.IOException
readFrameHeaderImpl
protected boolean readFrameHeaderImpl()
throws java.io.IOException
- Specified by:
readFrameHeaderImpl
in class FrameInputStream
- Throws:
java.io.IOException