org.tio.websocket.client

Class WebSocketImpl

java.lang.Object

org.tio.websocket.client.WebSocketImpl

All Implemented Interfaces:

WebSocket

public class WebSocketImpl
extends Object
implements WebSocket

Field Summary

Fields inherited from interface org.tio.websocket.client.WebSocket

CLOSED, CLOSING, CONNECTING, OPEN

Method Summary

Modifier and Type	Method and Description
Runnable	addOnClose(Consumer<CloseEvent> listener) To add listener of close event
Runnable	addOnError(Consumer<ErrorEvent> listener) To add listener of error event
Runnable	addOnMessage(Consumer<MessageEvent> listener) To add listener of message event
Runnable	addOnOpen(Consumer<OpenEvent> listener) To add listener of open event
Runnable	addOnThrows(Consumer<Throwable> listener) To add listener of throws event
void	close(int code, String reason) Close this WebSocket by code and reason
void	connect() Connect to server
String	getExtensions()
io.reactivex.Observable<WsPacket>	getMessageStream() Get message stream from server
String	getProtocol()
int	getReadyState() ready state: CONNECTING, OPEN, CLOSING, CLOSED
String	getUrl() url
void	send(String data) Send message to server
void	send(WsPacket packet) Send packet to server

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.tio.websocket.client.WebSocket

close, close, send, send

Method Detail

connect

public void connect()
             throws Exception

Description copied from interface: WebSocket

Connect to server

Specified by:

connect in interface WebSocket

Throws:

Exception

getExtensions

public String getExtensions()

Specified by:

getExtensions in interface WebSocket

addOnClose

public Runnable addOnClose(Consumer<CloseEvent> listener)

Description copied from interface: WebSocket

To add listener of close event

Specified by:

addOnClose in interface WebSocket

Parameters:

listener - listener

Returns:

Runnable to remove this listener

addOnError

public Runnable addOnError(Consumer<ErrorEvent> listener)

Description copied from interface: WebSocket

To add listener of error event

Specified by:

addOnError in interface WebSocket

Parameters:

listener - listener

Returns:

Runnable to remove this listener

addOnMessage

public Runnable addOnMessage(Consumer<MessageEvent> listener)

Description copied from interface: WebSocket

To add listener of message event

Specified by:

addOnMessage in interface WebSocket

Parameters:

listener - listener

Returns:

Runnable to remove this listener

addOnOpen

public Runnable addOnOpen(Consumer<OpenEvent> listener)

Description copied from interface: WebSocket

To add listener of open event

Specified by:

addOnOpen in interface WebSocket

Parameters:

listener - listener

Returns:

Runnable to remove this listener

addOnThrows

public Runnable addOnThrows(Consumer<Throwable> listener)

Description copied from interface: WebSocket

To add listener of throws event

Specified by:

addOnThrows in interface WebSocket

Parameters:

listener - listener

Returns:

Runnable to remove this listener

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface WebSocket

getReadyState

public int getReadyState()

Description copied from interface: WebSocket

ready state: CONNECTING, OPEN, CLOSING, CLOSED

Specified by:

getReadyState in interface WebSocket

Returns:

getUrl

public String getUrl()

Description copied from interface: WebSocket

url

Specified by:

getUrl in interface WebSocket

Returns:

close

public void close(int code,
                  String reason)

Description copied from interface: WebSocket

Close this WebSocket by code and reason

Specified by:

close in interface WebSocket

send

public void send(String data)

Description copied from interface: WebSocket

Send message to server

Specified by:

send in interface WebSocket

send

public void send(WsPacket packet)

Description copied from interface: WebSocket

Send packet to server

Specified by:

send in interface WebSocket

getMessageStream

public io.reactivex.Observable<WsPacket> getMessageStream()

Description copied from interface: WebSocket

Get message stream from server

Specified by:

getMessageStream in interface WebSocket

Returns: