META-INF/MANIFEST.MF
de/tavendo/autobahn/ByteBufferInputStream.class
ByteBufferInputStream.java package de.tavendo.autobahn public de.tavendo.autobahn.ByteBufferInputStream extends java.io.InputStream { private final java.nio.ByteBuffer mBuffer public void <init> (java.nio.ByteBuffer) java.nio.ByteBuffer buffer public synchronized int read () throws java.io.IOException public synchronized int read (byte[], int, int) throws java.io.IOException byte[] bytes int off int len int length }
de/tavendo/autobahn/ByteBufferOutputStream.class
ByteBufferOutputStream.java package de.tavendo.autobahn public de.tavendo.autobahn.ByteBufferOutputStream extends java.io.OutputStream { private final int mInitialSize private final int mGrowSize private java.nio.ByteBuffer mBuffer public void <init> () public void <init> (int, int) int initialSize int growSize public java.nio.ByteBuffer getBuffer () public java.nio.Buffer flip () public java.nio.Buffer clear () public int remaining () public synchronized void expand (int) int requestSize java.nio.ByteBuffer oldBuffer int oldPosition int newCapacity public synchronized void write (int) throws java.io.IOException int b public synchronized void write (byte[], int, int) throws java.io.IOException byte[] bytes int off int len public synchronized void write (byte[]) throws java.io.IOException byte[] bytes public synchronized void write (java.lang.String) throws java.io.IOException String str public synchronized void crlf () throws java.io.IOException }
de/tavendo/autobahn/Doxygen.class
Doxygen.java package de.tavendo.autobahn abstract de.tavendo.autobahn.Doxygen extends java.lang.Object { void <init> () }
de/tavendo/autobahn/NoCopyByteArrayOutputStream.class
NoCopyByteArrayOutputStream.java package de.tavendo.autobahn public de.tavendo.autobahn.NoCopyByteArrayOutputStream extends java.io.ByteArrayOutputStream { public void <init> () public void <init> (int) int size public java.io.InputStream getInputStream () public byte[] getByteArray () }
de/tavendo/autobahn/PrefixMap.class
PrefixMap.java package de.tavendo.autobahn public de.tavendo.autobahn.PrefixMap extends java.lang.Object { private final java.util.HashMap mPrefixes private final java.util.HashMap mUris public void <init> () public void set (java.lang.String, java.lang.String) String prefix String uri public java.lang.String get (java.lang.String) String prefix public java.lang.String remove (java.lang.String) String prefix String uri public void clear () public java.lang.String resolve (java.lang.String) String curie int i String prefix public java.lang.String resolveOrPass (java.lang.String) String curieOrUri String u public java.lang.String shrink (java.lang.String) String uri int i String u String p }
de/tavendo/autobahn/Utf8Validator.class
Utf8Validator.java package de.tavendo.autobahn public de.tavendo.autobahn.Utf8Validator extends java.lang.Object { private static final int[] DFA private static final int ACCEPT private static final int REJECT private int mState private int mPos static void <clinit> () public void <init> () public void reset () public int position () public boolean isValid () public boolean validate (byte[], int, int) byte[] data int off int len int i public boolean validate (byte[]) byte[] data }
de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification.class
WebSocket.java package de.tavendo.autobahn public final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification extends java.lang.Enum { public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification NORMAL public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification CANNOT_CONNECT public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification CONNECTION_LOST public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification PROTOCOL_ERROR public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification INTERNAL_ERROR public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification SERVER_ERROR public static final enum de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification RECONNECT private static final synthetic de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification[] ENUM$VALUES static void <clinit> () private void <init> (java.lang.String, int) public static de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification[] values () public static de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification valueOf (java.lang.String) }
de/tavendo/autobahn/WebSocket$WebSocketConnectionObserver.class
WebSocket.java package de.tavendo.autobahn public abstract de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver extends java.lang.Object { public abstract void onOpen () public abstract void onClose (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String) public abstract void onTextMessage (java.lang.String) public abstract void onRawTextMessage (byte[]) public abstract void onBinaryMessage (byte[]) }
de/tavendo/autobahn/WebSocket.class
WebSocket.java package de.tavendo.autobahn public abstract de.tavendo.autobahn.WebSocket extends java.lang.Object { public static final String UTF8_ENCODING public abstract void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver) throws de.tavendo.autobahn.WebSocketException public abstract void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver, de.tavendo.autobahn.WebSocketOptions) throws de.tavendo.autobahn.WebSocketException public abstract void disconnect () public abstract boolean isConnected () public abstract void sendBinaryMessage (byte[]) public abstract void sendRawTextMessage (byte[]) public abstract void sendTextMessage (java.lang.String) }
de/tavendo/autobahn/WebSocketConnection$1.class
WebSocketConnection.java package de.tavendo.autobahn de.tavendo.autobahn.WebSocketConnection$1 extends java.lang.Object implements java.lang.Runnable { final synthetic de.tavendo.autobahn.WebSocketConnection this$0 void <init> (de.tavendo.autobahn.WebSocketConnection) public void run () }
de/tavendo/autobahn/WebSocketConnection$2.class
WebSocketConnection.java package de.tavendo.autobahn de.tavendo.autobahn.WebSocketConnection$2 extends java.lang.Object implements java.lang.Runnable { final synthetic de.tavendo.autobahn.WebSocketConnection this$0 void <init> (de.tavendo.autobahn.WebSocketConnection) public void run () }
de/tavendo/autobahn/WebSocketConnection$3.class
WebSocketConnection.java package de.tavendo.autobahn de.tavendo.autobahn.WebSocketConnection$3 extends java.lang.Object implements java.lang.Runnable { final synthetic de.tavendo.autobahn.WebSocketConnection this$0 void <init> (de.tavendo.autobahn.WebSocketConnection) public void run () }
de/tavendo/autobahn/WebSocketConnection$4.class
WebSocketConnection.java package de.tavendo.autobahn de.tavendo.autobahn.WebSocketConnection$4 extends java.lang.Object implements java.lang.Runnable { final synthetic de.tavendo.autobahn.WebSocketConnection this$0 void <init> (de.tavendo.autobahn.WebSocketConnection) public void run () }
de/tavendo/autobahn/WebSocketConnection$SocketThread.class
WebSocketConnection.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketConnection$SocketThread extends java.lang.Thread { private static final String WS_CONNECTOR private final java.net.URI mWebSocketURI private java.net.Socket mSocket private String mFailureMessage private android.os.Handler mHandler public void <init> (java.net.URI, de.tavendo.autobahn.WebSocketOptions) java.net.URI uri de.tavendo.autobahn.WebSocketOptions options public void run () public void startConnection () String host int port javax.net.SocketFactory factory java.io.IOException e public void stopConnection () java.io.IOException e public android.os.Handler getHandler () public java.net.Socket getSocket () public java.lang.String getFailureMessage () }
de/tavendo/autobahn/WebSocketConnection$ThreadHandler.class
WebSocketConnection.java package de.tavendo.autobahn de.tavendo.autobahn.WebSocketConnection$ThreadHandler extends android.os.Handler { private final java.lang.ref.WeakReference mWebSocketConnection public void <init> (de.tavendo.autobahn.WebSocketConnection) de.tavendo.autobahn.WebSocketConnection webSocketConnection public void handleMessage (android.os.Message) android.os.Message message de.tavendo.autobahn.WebSocketConnection webSocketConnection }
de/tavendo/autobahn/WebSocketConnection.class
WebSocketConnection.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketConnection extends java.lang.Object implements de.tavendo.autobahn.WebSocket { private static final String TAG private static final String WS_URI_SCHEME private static final String WSS_URI_SCHEME private static final String WS_WRITER private static final String WS_READER private final android.os.Handler mHandler private de.tavendo.autobahn.WebSocketReader mWebSocketReader private de.tavendo.autobahn.WebSocketWriter mWebSocketWriter private java.net.Socket mSocket private de.tavendo.autobahn.WebSocketConnection$SocketThread mSocketThread private java.net.URI mWebSocketURI private String[] mWebSocketSubprotocols private java.lang.ref.WeakReference mWebSocketConnectionObserver private de.tavendo.autobahn.WebSocketOptions mWebSocketOptions private boolean mPreviousConnection static void <clinit> () public void <init> () public void sendTextMessage (java.lang.String) String payload public void sendRawTextMessage (byte[]) byte[] payload public void sendBinaryMessage (byte[]) byte[] payload public boolean isConnected () private void failConnection (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String) de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification code String reason InterruptedException e InterruptedException e public void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver) throws de.tavendo.autobahn.WebSocketException java.net.URI webSocketURI de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver connectionObserver public void connect (java.net.URI, de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver, de.tavendo.autobahn.WebSocketOptions) throws de.tavendo.autobahn.WebSocketException java.net.URI webSocketURI de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver connectionObserver de.tavendo.autobahn.WebSocketOptions options public void connect (java.net.URI, java.lang.String[], de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver, de.tavendo.autobahn.WebSocketOptions) throws de.tavendo.autobahn.WebSocketException java.net.URI webSocketURI String[] subprotocols de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver connectionObserver de.tavendo.autobahn.WebSocketOptions options public void disconnect () public boolean reconnect () private void connect () de.tavendo.autobahn.WebSocketMessage$ClientHandshake clientHandshake Exception e protected boolean scheduleReconnect () int interval boolean shouldReconnect private void onClose (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String) de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification code String reason boolean reconnecting de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver webSocketObserver Exception e protected void processAppMessage (java.lang.Object) Object message protected void createWriter () protected void createReader () private void handleMessage (android.os.Message) android.os.Message message de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver webSocketObserver de.tavendo.autobahn.WebSocketMessage$TextMessage textMessage de.tavendo.autobahn.WebSocketMessage$RawTextMessage rawTextMessage de.tavendo.autobahn.WebSocketMessage$BinaryMessage binaryMessage de.tavendo.autobahn.WebSocketMessage$Ping ping de.tavendo.autobahn.WebSocketMessage$Pong pong de.tavendo.autobahn.WebSocketMessage$Pong pong de.tavendo.autobahn.WebSocketMessage$Close close de.tavendo.autobahn.WebSocketMessage$ServerHandshake serverHandshake de.tavendo.autobahn.WebSocketMessage$Error error de.tavendo.autobahn.WebSocketMessage$ServerError error static synthetic java.lang.String access$0 () static synthetic void access$1 (de.tavendo.autobahn.WebSocketConnection, android.os.Message) static synthetic de.tavendo.autobahn.WebSocketConnection$SocketThread access$2 (de.tavendo.autobahn.WebSocketConnection) }
de/tavendo/autobahn/WebSocketConnectionHandler.class
WebSocketConnectionHandler.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketConnectionHandler extends java.lang.Object implements de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver { public void <init> () public void onOpen () public void onClose (de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification, java.lang.String) de.tavendo.autobahn.WebSocket$WebSocketConnectionObserver$WebSocketCloseNotification code String reason public void onTextMessage (java.lang.String) String payload public void onRawTextMessage (byte[]) byte[] payload public void onBinaryMessage (byte[]) byte[] payload }
de/tavendo/autobahn/WebSocketException.class
WebSocketException.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketException extends java.lang.Exception { private static final long serialVersionUID public void <init> (java.lang.String) String message public void <init> (java.lang.String, java.lang.Throwable) String message Throwable t }
de/tavendo/autobahn/WebSocketFrameHeader.class
WebSocketFrameHeader.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketFrameHeader extends java.lang.Object { private int mOpcode private boolean mFin private int mReserved private int mHeaderLen private int mPayloadLen private int mTotalLen private byte[] mMask public void <init> () public int getOpcode () public void setOpcode (int) int opcode public boolean isFin () public void setFin (boolean) boolean fin public int getReserved () public void setReserved (int) int reserved public int getHeaderLength () public void setHeaderLength (int) int headerLength public int getPayloadLength () public void setPayloadLength (int) int payloadLength public int getTotalLength () public void setTotalLen (int) int totalLength public byte[] getMask () public void setMask (byte[]) byte[] mask }
de/tavendo/autobahn/WebSocketMessage$BinaryMessage.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$BinaryMessage extends de.tavendo.autobahn.WebSocketMessage$Message { public byte[] mPayload void <init> (byte[]) byte[] payload }
de/tavendo/autobahn/WebSocketMessage$ClientHandshake.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$ClientHandshake extends de.tavendo.autobahn.WebSocketMessage$Message { private final java.net.URI mURI private final java.net.URI mOrigin private final String[] mSubprotocols void <init> (java.net.URI) java.net.URI uri void <init> (java.net.URI, java.net.URI, java.lang.String[]) java.net.URI uri java.net.URI origin String[] subprotocols public java.net.URI getURI () public java.net.URI getOrigin () public java.lang.String[] getSubprotocols () }
de/tavendo/autobahn/WebSocketMessage$Close.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$Close extends de.tavendo.autobahn.WebSocketMessage$Message { private int mCode private String mReason void <init> () void <init> (int) int code void <init> (int, java.lang.String) int code String reason public int getCode () public java.lang.String getReason () }
de/tavendo/autobahn/WebSocketMessage$ConnectionLost.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$ConnectionLost extends de.tavendo.autobahn.WebSocketMessage$Message { public void <init> () }
de/tavendo/autobahn/WebSocketMessage$Error.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$Error extends de.tavendo.autobahn.WebSocketMessage$Message { public Exception mException public void <init> (java.lang.Exception) Exception e }
de/tavendo/autobahn/WebSocketMessage$Message.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$Message extends java.lang.Object { public void <init> () }
de/tavendo/autobahn/WebSocketMessage$Ping.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$Ping extends de.tavendo.autobahn.WebSocketMessage$Message { public byte[] mPayload void <init> () void <init> (byte[]) byte[] payload }
de/tavendo/autobahn/WebSocketMessage$Pong.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$Pong extends de.tavendo.autobahn.WebSocketMessage$Message { public byte[] mPayload void <init> () void <init> (byte[]) byte[] payload }
de/tavendo/autobahn/WebSocketMessage$ProtocolViolation.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$ProtocolViolation extends de.tavendo.autobahn.WebSocketMessage$Message { public de.tavendo.autobahn.WebSocketException mException public void <init> (de.tavendo.autobahn.WebSocketException) de.tavendo.autobahn.WebSocketException e }
de/tavendo/autobahn/WebSocketMessage$Quit.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$Quit extends de.tavendo.autobahn.WebSocketMessage$Message { public void <init> () }
de/tavendo/autobahn/WebSocketMessage$RawTextMessage.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$RawTextMessage extends de.tavendo.autobahn.WebSocketMessage$Message { public byte[] mPayload void <init> (byte[]) byte[] payload }
de/tavendo/autobahn/WebSocketMessage$ServerError.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$ServerError extends de.tavendo.autobahn.WebSocketMessage$Message { public int mStatusCode public String mStatusMessage public void <init> (int, java.lang.String) int statusCode String statusMessage }
de/tavendo/autobahn/WebSocketMessage$ServerHandshake.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$ServerHandshake extends de.tavendo.autobahn.WebSocketMessage$Message { public boolean mSuccess public void <init> (boolean) boolean success }
de/tavendo/autobahn/WebSocketMessage$TextMessage.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$TextMessage extends de.tavendo.autobahn.WebSocketMessage$Message { public String mPayload void <init> (java.lang.String) String payload }
de/tavendo/autobahn/WebSocketMessage$WebSocketCloseCode.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage$WebSocketCloseCode extends java.lang.Object { public static final int NORMAL public static final int ENDPOINT_GOING_AWAY public static final int ENDPOINT_PROTOCOL_ERROR public static final int ENDPOINT_UNSUPPORTED_DATA_TYPE public static final int RESERVED public static final int RESERVED_NO_STATUS public static final int RESERVED_NO_CLOSING_HANDSHAKE public static final int ENDPOINT_BAD_DATA public static final int POLICY_VIOLATION public static final int MESSAGE_TOO_BIG public static final int ENDPOINT_NEEDS_EXTENSION public static final int UNEXPECTED_CONDITION public static final int RESERVED_TLS_REQUIRED public void <init> () }
de/tavendo/autobahn/WebSocketMessage.class
WebSocketMessage.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketMessage extends java.lang.Object { public void <init> () }
de/tavendo/autobahn/WebSocketOptions.class
WebSocketOptions.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketOptions extends java.lang.Object { private int mMaxFramePayloadSize private int mMaxMessagePayloadSize private boolean mReceiveTextMessagesRaw private boolean mTcpNoDelay private int mSocketReceiveTimeout private int mSocketConnectTimeout private boolean mValidateIncomingUtf8 private boolean mMaskClientFrames private int mReconnectInterval public void <init> () public void <init> (de.tavendo.autobahn.WebSocketOptions) de.tavendo.autobahn.WebSocketOptions other public void setReceiveTextMessagesRaw (boolean) boolean enabled public boolean getReceiveTextMessagesRaw () public void setMaxFramePayloadSize (int) int size public int getMaxFramePayloadSize () public void setMaxMessagePayloadSize (int) int size public int getMaxMessagePayloadSize () public void setTcpNoDelay (boolean) boolean enabled public boolean getTcpNoDelay () public void setSocketReceiveTimeout (int) int timeoutMs public int getSocketReceiveTimeout () public void setSocketConnectTimeout (int) int timeoutMs public int getSocketConnectTimeout () public void setValidateIncomingUtf8 (boolean) boolean enabled public boolean getValidateIncomingUtf8 () public void setMaskClientFrames (boolean) boolean enabled public boolean getMaskClientFrames () public void setReconnectInterval (int) int reconnectInterval public int getReconnectInterval () }
de/tavendo/autobahn/WebSocketReader$ReaderState.class
WebSocketReader.java package de.tavendo.autobahn final enum de.tavendo.autobahn.WebSocketReader$ReaderState extends java.lang.Enum { public static final enum de.tavendo.autobahn.WebSocketReader$ReaderState STATE_CLOSED public static final enum de.tavendo.autobahn.WebSocketReader$ReaderState STATE_CONNECTING public static final enum de.tavendo.autobahn.WebSocketReader$ReaderState STATE_CLOSING public static final enum de.tavendo.autobahn.WebSocketReader$ReaderState STATE_OPEN private static final synthetic de.tavendo.autobahn.WebSocketReader$ReaderState[] ENUM$VALUES static void <clinit> () private void <init> (java.lang.String, int) public static de.tavendo.autobahn.WebSocketReader$ReaderState[] values () public static de.tavendo.autobahn.WebSocketReader$ReaderState valueOf (java.lang.String) }
de/tavendo/autobahn/WebSocketReader.class
WebSocketReader.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketReader extends java.lang.Thread { private static final String TAG private final android.os.Handler mWebSocketConnectionHandler private final java.net.Socket mSocket private java.io.InputStream mInputStream private final de.tavendo.autobahn.WebSocketOptions mWebSocketOptions private volatile boolean mStopped private final byte[] mNetworkBuffer private final java.nio.ByteBuffer mApplicationBuffer private de.tavendo.autobahn.NoCopyByteArrayOutputStream mMessagePayload private de.tavendo.autobahn.WebSocketReader$ReaderState mState private boolean mInsideMessage private int mMessageOpcode private de.tavendo.autobahn.WebSocketFrameHeader mFrameHeader private de.tavendo.autobahn.Utf8Validator mUTF8Validator private static synthetic int[] $SWITCH_TABLE$de$tavendo$autobahn$WebSocketReader$ReaderState static void <clinit> () public void <init> (android.os.Handler, java.net.Socket, de.tavendo.autobahn.WebSocketOptions, java.lang.String) android.os.Handler master java.net.Socket socket de.tavendo.autobahn.WebSocketOptions options String threadName public void quit () protected void notify (java.lang.Object) Object message android.os.Message msg private boolean processData () throws java.lang.Exception byte b0 boolean fin int rsv int opcode byte b1 boolean masked int payload_len1 int mask_len int header_len int i long payload_len byte[] mask int j byte[] framePayload int oldPosition int code String reason byte[] ra de.tavendo.autobahn.Utf8Validator val String s protected void onHandshake (boolean) boolean success protected void onClose (int, java.lang.String) int code String reason protected void onPing (byte[]) byte[] payload protected void onPong (byte[]) byte[] payload protected void onTextMessage (java.lang.String) String payload protected void onRawTextMessage (byte[]) byte[] payload protected void onBinaryMessage (byte[]) byte[] payload private boolean processHandshake () throws java.io.UnsupportedEncodingException boolean res int pos int oldPosition boolean serverError android.util.Pair status private android.util.Pair parseHTTPStatus () throws java.io.UnsupportedEncodingException int beg int end int statusCode int i int digit int eol int statusMessageLength byte[] statusBuf String statusMessage private boolean consumeData () throws java.lang.Exception public void run () java.io.InputStream inputStream java.io.IOException e int bytesRead de.tavendo.autobahn.WebSocketException e java.net.SocketException e java.io.IOException e Exception e static synthetic int[] $SWITCH_TABLE$de$tavendo$autobahn$WebSocketReader$ReaderState () }
de/tavendo/autobahn/WebSocketWriter$ThreadHandler.class
WebSocketWriter.java package de.tavendo.autobahn de.tavendo.autobahn.WebSocketWriter$ThreadHandler extends android.os.Handler { private final java.lang.ref.WeakReference mWebSocketWriterReference public void <init> (de.tavendo.autobahn.WebSocketWriter) de.tavendo.autobahn.WebSocketWriter webSocketWriter public void handleMessage (android.os.Message) android.os.Message message de.tavendo.autobahn.WebSocketWriter webSocketWriter }
de/tavendo/autobahn/WebSocketWriter.class
WebSocketWriter.java package de.tavendo.autobahn public de.tavendo.autobahn.WebSocketWriter extends java.lang.Thread { private static final String TAG private static final int WEB_SOCKETS_VERSION private static final String CRLF private final java.util.Random mRandom private final android.os.Handler mWebSocketConnectionHandler private final de.tavendo.autobahn.WebSocketOptions mWebSocketOptions private final java.nio.ByteBuffer mApplicationBuffer private final java.net.Socket mSocket private java.io.OutputStream mOutputStream private android.os.Handler mHandler static void <clinit> () public void <init> (android.os.Handler, java.net.Socket, de.tavendo.autobahn.WebSocketOptions, java.lang.String) android.os.Handler master java.net.Socket socket de.tavendo.autobahn.WebSocketOptions options String threadName public void forward (java.lang.Object) Object message android.os.Message msg private void notify (java.lang.Object) Object message android.os.Message msg private java.lang.String newHandshakeKey () byte[] ba private byte[] newFrameMask () byte[] ba private void sendClientHandshake (de.tavendo.autobahn.WebSocketMessage$ClientHandshake) throws java.io.IOException de.tavendo.autobahn.WebSocketMessage$ClientHandshake message String path String query int i private void sendClose (de.tavendo.autobahn.WebSocketMessage$Close) throws java.io.IOException de.tavendo.autobahn.WebSocketException de.tavendo.autobahn.WebSocketMessage$Close message byte[] payload byte[] pReason int i private void sendPing (de.tavendo.autobahn.WebSocketMessage$Ping) throws java.io.IOException de.tavendo.autobahn.WebSocketException de.tavendo.autobahn.WebSocketMessage$Ping message private void sendPong (de.tavendo.autobahn.WebSocketMessage$Pong) throws java.io.IOException de.tavendo.autobahn.WebSocketException de.tavendo.autobahn.WebSocketMessage$Pong message private void sendBinaryMessage (de.tavendo.autobahn.WebSocketMessage$BinaryMessage) throws java.io.IOException de.tavendo.autobahn.WebSocketException de.tavendo.autobahn.WebSocketMessage$BinaryMessage message private void sendTextMessage (de.tavendo.autobahn.WebSocketMessage$TextMessage) throws java.io.IOException de.tavendo.autobahn.WebSocketException de.tavendo.autobahn.WebSocketMessage$TextMessage message byte[] payload private void sendRawTextMessage (de.tavendo.autobahn.WebSocketMessage$RawTextMessage) throws java.io.IOException de.tavendo.autobahn.WebSocketException de.tavendo.autobahn.WebSocketMessage$RawTextMessage message protected void sendFrame (int, boolean, byte[]) throws java.io.IOException int opcode boolean fin byte[] payload protected void sendFrame (int, boolean, byte[], int, int) throws java.io.IOException int opcode boolean fin byte[] payload int offset int length byte b0 byte b1 long len byte[] mask int i protected void processMessage (java.lang.Object) throws java.io.IOException de.tavendo.autobahn.WebSocketException Object msg public void writeMessageToBuffer (android.os.Message) android.os.Message message java.net.SocketException e java.io.IOException e Exception e protected void processAppMessage (java.lang.Object) throws de.tavendo.autobahn.WebSocketException java.io.IOException Object msg public void run () java.io.OutputStream outputStream java.io.IOException e }