Modifier and Type	Class and Description
public static interface	TyrusClientEngine.ClientHandshakeListener Called when response is received from the server.
private static enum	TyrusClientEngine.TyrusClientEngineState State controls flow in `processResponse(UpgradeResponse, Writer, Connection.CloseListener)` and depends on upgrade response status code and previous state.
private static class	TyrusClientEngine.TyrusReadHandler

Modifier and Type	Field and Description
private static final int	BUFFER_STEP_SIZE
private volatile TyrusClientEngine.TyrusClientEngineState	clientEngineState
private volatile Handshake	clientHandShake
private final URI	connectToServerUriParam
private final DebugContext	debugContext
public static final int	DEFAULT_INCOMING_BUFFER_SIZE Default incoming buffer size for client container.
private static final int	DEFAULT_REDIRECT_THRESHOLD
private static final Version	DEFAULT_VERSION
private final TyrusEndpointWrapper	endpointWrapper
private final TyrusClientEngine.ClientHandshakeListener	listener
private static final Logger	LOGGER
private final boolean	logUpgradeMessages
private final Map<String, Object>	properties
private final ProtocolHandler	protocolHandler
private final Boolean	redirectEnabled
private volatile URI	redirectLocation
private final int	redirectThreshold
private final Set<URI>	redirectUriHistory
private volatile ClientEngine.TimeoutHandler	timeoutHandler
private static final ClientEngine.ClientUpgradeInfo	UPGRADE_INFO_ANOTHER_REQUEST_REQUIRED
private static final ClientEngine.ClientUpgradeInfo	UPGRADE_INFO_FAILED

Constructor Summary

Access Constructor and Description

Access	Constructor and Description
pack-priv	TyrusClientEngine(TyrusEndpointWrapper wrapped client endpoint. endpointWrapper, TyrusClientEngine.ClientHandshakeListener used for reporting back the outcome of handshake. `ClientHandshakeListener#onSessionCreated(jakarta.websocket.Session)` is invoked if handshake is completed and provided `Session` is open and ready to be returned from `WebSocketContainer#connectToServer(Class, jakarta.websocket.ClientEndpointConfig, java.net.URI)` (and alternatives) call. listener, Map<String, Object> passed container properties, see `* .ClientManager#getProperties()`. properties, URI to which the client is connecting. connectToServerUriParam, DebugContext debug context. debugContext) Create `org.glassfish.tyrus.spi.WebSocketEngine` instance based on passed `WebSocketContainer` and with configured maximal incoming buffer size.

pack-priv

wrapped client endpoint.

endpointWrapper, TyrusClientEngine.ClientHandshakeListener

used for reporting back the outcome of handshake. ClientHandshakeListener#onSessionCreated(jakarta.websocket.Session) is invoked if handshake is completed and provided Session is open and ready to be returned from

WebSocketContainer#connectToServer(Class,
                               jakarta.websocket.ClientEndpointConfig, java.net.URI)

(and alternatives) call.

listener, Map<String, Object>

passed container properties, see

*
                               .ClientManager#getProperties()

properties, URI

to which the client is connecting.

connectToServerUriParam, DebugContext

debug context.

debugContext)

Create org.glassfish.tyrus.spi.WebSocketEngine instance based on passed WebSocketContainer and with configured maximal incoming buffer size.

Method Summary

Modifier and Type	Method and Description
public UpgradeRequest	createUpgradeRequest(ClientEngine.TimeoutHandler handshake timeout handler. `TimeoutHandler#handleTimeout()` is invoked if `processResponse(UpgradeResponse, Writer, Connection.CloseListener)` is not called within handshake timeout. timeoutHandler) Implements org.glassfish.tyrus.spi.ClientEngine.createUpgradeRequest. Create upgrade request and register `TimeoutHandler`.
public ClientEngine.TimeoutHandler	Returns: timeout handler instance or `null` when not present. getTimeoutHandler() Get `TimeoutHandler` associated with current `ClientEngine` instance.
private ClientEngine.ClientUpgradeInfo	handleAuth(UpgradeResponse upgradeResponse)
private ClientEngine.ClientUpgradeInfo	handleRedirect(UpgradeResponse upgradeResponse)
private ClientEngine.ClientUpgradeInfo	handleSwitchProtocol(UpgradeResponse upgradeResponse, Writer writer, Connection.CloseListener closeListener)
private void	logUpgradeRequest(UpgradeRequest upgradeRequest)
public void	processError(Throwable encountered error. t) Implements org.glassfish.tyrus.spi.ClientEngine.processError. Process error.
public ClientEngine.ClientUpgradeInfo	processResponse(final UpgradeResponse response to be processed. upgradeResponse, final Writer used for sending dataframes from client endpoint. writer, final Connection.CloseListener will be called when connection is closed, will be set as listener of returned `Connection`. closeListener) Implements org.glassfish.tyrus.spi.ClientEngine.processResponse. Process handshake and return `ClientUpgradeInfo` with handshake status (`ClientUpgradeStatus`).
private ClientEngine.ClientUpgradeInfo	Returns: client upgrade info with `ClientUpgradeStatus#SUCCESS` status. processUpgradeResponse(UpgradeResponse upgrade response received from client container. upgradeResponse, final Writer writer instance to be used for sending websocket frames. writer, final Connection.CloseListener client container connection listener. closeListener) Process upgrade response.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

BUFFER_STEP_SIZE	back to summary
private static final int BUFFER_STEP_SIZE

clientEngineState	back to summary
private volatile TyrusClientEngine.TyrusClientEngineState clientEngineState

clientHandShake	back to summary
private volatile Handshake clientHandShake

connectToServerUriParam	back to summary
private final URI connectToServerUriParam

debugContext	back to summary
private final DebugContext debugContext

DEFAULT_INCOMING_BUFFER_SIZE	back to summary
public static final int DEFAULT_INCOMING_BUFFER_SIZE Default incoming buffer size for client container.

DEFAULT_REDIRECT_THRESHOLD	back to summary
private static final int DEFAULT_REDIRECT_THRESHOLD

DEFAULT_VERSION	back to summary
private static final Version DEFAULT_VERSION

endpointWrapper	back to summary
private final TyrusEndpointWrapper endpointWrapper

listener	back to summary
private final TyrusClientEngine.ClientHandshakeListener listener

LOGGER	back to summary
private static final Logger LOGGER

logUpgradeMessages	back to summary
private final boolean logUpgradeMessages

properties	back to summary
private final Map<String, Object> properties

protocolHandler	back to summary
private final ProtocolHandler protocolHandler

redirectEnabled	back to summary
private final Boolean redirectEnabled

redirectLocation	back to summary
private volatile URI redirectLocation

redirectThreshold	back to summary
private final int redirectThreshold

redirectUriHistory	back to summary
private final Set<URI> redirectUriHistory

timeoutHandler	back to summary
private volatile ClientEngine.TimeoutHandler timeoutHandler

UPGRADE_INFO_ANOTHER_REQUEST_REQUIRED	back to summary
private static final ClientEngine.ClientUpgradeInfo UPGRADE_INFO_ANOTHER_REQUEST_REQUIRED

UPGRADE_INFO_FAILED	back to summary
private static final ClientEngine.ClientUpgradeInfo UPGRADE_INFO_FAILED

Constructor Detail

TyrusClientEngine back to summary

TyrusClientEngine	back to summary
pack-priv TyrusClientEngine(TyrusEndpointWrapper endpointWrapper, TyrusClientEngine.ClientHandshakeListener listener, Map<String, Object> properties, URI connectToServerUriParam, DebugContext debugContext) Create `org.glassfish.tyrus.spi.WebSocketEngine` instance based on passed `WebSocketContainer` and with configured maximal incoming buffer size. Parameters endpointWrapper:TyrusEndpointWrapper wrapped client endpoint. listener:TyrusClientEngine.ClientHandshakeListener used for reporting back the outcome of handshake. `ClientHandshakeListener#onSessionCreated(jakarta.websocket.Session)` is invoked if handshake is completed and provided `Session` is open and ready to be returned from `WebSocketContainer#connectToServer(Class, jakarta.websocket.ClientEndpointConfig, java.net.URI)` (and alternatives) call. properties:Map<String, Object> passed container properties, see `* .ClientManager#getProperties()`. connectToServerUriParam:URI to which the client is connecting. debugContext:DebugContext debug context.

pack-priv TyrusClientEngine(TyrusEndpointWrapper endpointWrapper, TyrusClientEngine.ClientHandshakeListener listener, Map<String, Object> properties, URI connectToServerUriParam, DebugContext debugContext)

Create org.glassfish.tyrus.spi.WebSocketEngine instance based on passed WebSocketContainer and with configured maximal incoming buffer size.

Parameters

endpointWrapper:TyrusEndpointWrapper: wrapped client endpoint.
listener:TyrusClientEngine.ClientHandshakeListener: used for reporting back the outcome of handshake. ClientHandshakeListener#onSessionCreated(jakarta.websocket.Session) is invoked if handshake is completed and provided Session is open and ready to be returned from WebSocketContainer#connectToServer(Class, jakarta.websocket.ClientEndpointConfig, java.net.URI) (and alternatives) call.
properties:Map<String, Object>: passed container properties, see * .ClientManager#getProperties().
connectToServerUriParam:URI: to which the client is connecting.
debugContext:DebugContext: debug context.

Method Detail

createUpgradeRequest back to summary

createUpgradeRequest	back to summary
public UpgradeRequest createUpgradeRequest(ClientEngine.TimeoutHandler timeoutHandler) Implements org.glassfish.tyrus.spi.ClientEngine.createUpgradeRequest. Doc from org.glassfish.tyrus.spi.ClientEngine.createUpgradeRequest. Create upgrade request and register `TimeoutHandler`. Parameters timeoutHandler:ClientEngine.TimeoutHandler handshake timeout handler. `TimeoutHandler#handleTimeout()` is invoked if `processResponse(UpgradeResponse, Writer, Connection.CloseListener)` is not called within handshake timeout. Returns:UpgradeRequest request to be send on the wire or `null`, when the request cannot be created. When `null` is returned, client should free all resources tied to current connection. Annotations @Override

public UpgradeRequest createUpgradeRequest(ClientEngine.TimeoutHandler timeoutHandler)

Implements org.glassfish.tyrus.spi.ClientEngine.createUpgradeRequest.

Doc from org.glassfish.tyrus.spi.ClientEngine.createUpgradeRequest.

Create upgrade request and register TimeoutHandler.

Parameters

timeoutHandler:ClientEngine.TimeoutHandler: handshake timeout handler. TimeoutHandler#handleTimeout() is invoked if processResponse(UpgradeResponse, Writer, Connection.CloseListener) is not called within handshake timeout.

Returns:UpgradeRequest

request to be send on the wire or null, when the request cannot be created. When null is returned, client should free all resources tied to current connection.

Annotations

@Override

getTimeoutHandler back to summary

getTimeoutHandler	back to summary
public ClientEngine.TimeoutHandler getTimeoutHandler() Get `TimeoutHandler` associated with current `ClientEngine` instance. Returns:ClientEngine.TimeoutHandler timeout handler instance or `null` when not present.

public ClientEngine.TimeoutHandler getTimeoutHandler()

Get TimeoutHandler associated with current ClientEngine instance.

Returns:ClientEngine.TimeoutHandler: timeout handler instance or null when not present.

handleAuth	back to summary
private ClientEngine.ClientUpgradeInfo handleAuth(UpgradeResponse upgradeResponse)

handleRedirect	back to summary
private ClientEngine.ClientUpgradeInfo handleRedirect(UpgradeResponse upgradeResponse)

handleSwitchProtocol	back to summary
private ClientEngine.ClientUpgradeInfo handleSwitchProtocol(UpgradeResponse upgradeResponse, Writer writer, Connection.CloseListener closeListener)

logUpgradeRequest	back to summary
private void logUpgradeRequest(UpgradeRequest upgradeRequest)

processError back to summary

processError	back to summary
public void processError(Throwable t) Implements org.glassfish.tyrus.spi.ClientEngine.processError. Doc from org.glassfish.tyrus.spi.ClientEngine.processError. Process error. This method can be called any time when client encounters an error which cannot be handled in the container before `ClientUpgradeStatus#SUCCESS` is returned from `processResponse(UpgradeResponse, Writer, Connection.CloseListener)`. Parameters t:Throwable encountered error. Annotations @Override

public void processError(Throwable t)

Implements org.glassfish.tyrus.spi.ClientEngine.processError.

Doc from org.glassfish.tyrus.spi.ClientEngine.processError.

Process error.

This method can be called any time when client encounters an error which cannot be handled in the container before ClientUpgradeStatus#SUCCESS is returned from processResponse(UpgradeResponse, Writer, Connection.CloseListener).

Parameters

t:Throwable: encountered error.

Annotations

@Override

processResponse back to summary

processResponse	back to summary
public ClientEngine.ClientUpgradeInfo processResponse(final UpgradeResponse upgradeResponse, final Writer writer, final Connection.CloseListener closeListener) Implements org.glassfish.tyrus.spi.ClientEngine.processResponse. Doc from org.glassfish.tyrus.spi.ClientEngine.processResponse. Process handshake and return `ClientUpgradeInfo` with handshake status (`ClientUpgradeStatus`). Parameters upgradeResponse:UpgradeResponse response to be processed. writer:Writer used for sending dataframes from client endpoint. closeListener:Connection.CloseListener will be called when connection is closed, will be set as listener of returned `Connection`. Returns:ClientEngine.ClientUpgradeInfo info with upgrade status. Annotations @Override

public ClientEngine.ClientUpgradeInfo processResponse(final UpgradeResponse upgradeResponse, final Writer writer, final Connection.CloseListener closeListener)

Implements org.glassfish.tyrus.spi.ClientEngine.processResponse.

Doc from org.glassfish.tyrus.spi.ClientEngine.processResponse.

Process handshake and return ClientUpgradeInfo with handshake status (ClientUpgradeStatus).

Parameters

upgradeResponse:UpgradeResponse: response to be processed.
writer:Writer: used for sending dataframes from client endpoint.
closeListener:Connection.CloseListener: will be called when connection is closed, will be set as listener of returned Connection.

Returns:ClientEngine.ClientUpgradeInfo

info with upgrade status.

Annotations

@Override

processUpgradeResponse back to summary

processUpgradeResponse	back to summary
private ClientEngine.ClientUpgradeInfo processUpgradeResponse(UpgradeResponse upgradeResponse, final Writer writer, final Connection.CloseListener closeListener) throws HandshakeException Process upgrade response. This method should be called only when the response HTTP status code is `101`. Parameters upgradeResponse:UpgradeResponse upgrade response received from client container. writer:Writer writer instance to be used for sending websocket frames. closeListener:Connection.CloseListener client container connection listener. Returns:ClientEngine.ClientUpgradeInfo client upgrade info with `ClientUpgradeStatus#SUCCESS` status. Exceptions HandshakeException: when there is a problem with passed `UpgradeResponse`.

private ClientEngine.ClientUpgradeInfo processUpgradeResponse(UpgradeResponse upgradeResponse, final Writer writer, final Connection.CloseListener closeListener) throws HandshakeException

Process upgrade response. This method should be called only when the response HTTP status code is 101.

Parameters

upgradeResponse:UpgradeResponse: upgrade response received from client container.
writer:Writer: writer instance to be used for sending websocket frames.
closeListener:Connection.CloseListener: client container connection listener.

Returns:ClientEngine.ClientUpgradeInfo

client upgrade info with ClientUpgradeStatus#SUCCESS status.

Exceptions

HandshakeException:: when there is a problem with passed UpgradeResponse.

org.glassfish.tyrus.client back to summary

public Interface TyrusClientEngine.ClientHandshakeListener

Known Direct Subinterfaces: org.glassfish.tyrus.client.ClientManager.ClientManagerHandshakeListener

Called when response is received from the server.

Method Summary

Modifier and Type	Method and Description
public void	onError(Throwable error found during handshake response check. exception) Called when an error is found in handshake response.
public void	onSessionCreated(Session opened client session. session) Invoked when handshake is completed and provided `Session` is open and ready to be returned from `WebSocketContainer#connectToServer(Class, jakarta.websocket.ClientEndpointConfig, java.net.URI)` (and alternatives) call.

Method Detail

onError	back to summary
public void onError(Throwable exception) Called when an error is found in handshake response. Parameters exception:Throwable error found during handshake response check.

onError

back to summary

public void onError(Throwable exception)

Called when an error is found in handshake response.

Parameters

exception:Throwable: error found during handshake response check.

onSessionCreated back to summary

onSessionCreated	back to summary
public void onSessionCreated(Session session) Invoked when handshake is completed and provided `Session` is open and ready to be returned from `WebSocketContainer#connectToServer(Class, jakarta.websocket.ClientEndpointConfig, java.net.URI)` (and alternatives) call. Parameters session:Session opened client session.

public void onSessionCreated(Session session)

Invoked when handshake is completed and provided Session is open and ready to be returned from WebSocketContainer#connectToServer(Class, jakarta.websocket.ClientEndpointConfig, java.net.URI) (and alternatives) call.

Parameters

session:Session: opened client session.

org.glassfish.tyrus.client back to summary

private final Enum TyrusClientEngine.TyrusClientEngineState

Class Inheritance

extends Enum<TyrusClientEngine.TyrusClientEngineState>

java.lang.Object
java.lang.Enum
org.glassfish.tyrus.client.TyrusClientEngine.TyrusClientEngineState

State controls flow in processResponse(UpgradeResponse, Writer, Connection.CloseListener) and depends on upgrade response status code and previous state.

Field Summary

Modifier and Type	Field and Description
public static final TyrusClientEngine.TyrusClientEngineState	AUTH_REQUIRED Authentication required.
public static final TyrusClientEngine.TyrusClientEngineState	AUTH_UPGRADE_REQUEST_CREATED Upgrade request with Authorization header has been created.
private volatile Authenticator	authenticator
public static final TyrusClientEngine.TyrusClientEngineState	FAILED Handshake failed (final state).
public static final TyrusClientEngine.TyrusClientEngineState	INIT Initial state.
public static final TyrusClientEngine.TyrusClientEngineState	REDIRECT_REQUIRED Upgrade request must be redirected.
public static final TyrusClientEngine.TyrusClientEngineState	SUCCESS Handshake succeeded (final state).
public static final TyrusClientEngine.TyrusClientEngineState	UPGRADE_REQUEST_CREATED Upgrade request has been created.
private volatile String	wwwAuthenticateHeader

Constructor Summary

Access	Constructor and Description
private	TyrusClientEngineState()

Method Summary

Modifier and Type	Method and Description
pack-priv Authenticator	getAuthenticator()
pack-priv String	getWwwAuthenticateHeader()
pack-priv void	setAuthenticator(Authenticator authenticator)
pack-priv void	setWwwAuthenticateHeader(String wwwAuthenticateHeader)
public static TyrusClientEngine.TyrusClientEngineState	valueOf(String name)
public static TyrusClientEngine.TyrusClientEngineState[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

AUTH_REQUIRED back to summary

AUTH_REQUIRED	back to summary
public static final TyrusClientEngine.TyrusClientEngineState AUTH_REQUIRED Authentication required. Set in `processResponse(UpgradeResponse, Writer, Connection.CloseListener)` when 401 HTTP status code is received and the last upgrade request does not contain Authorization header (the last state was not `AUTH_UPGRADE_REQUEST_CREATED`).

public static final TyrusClientEngine.TyrusClientEngineState AUTH_REQUIRED

Authentication required.

Set in processResponse(UpgradeResponse, Writer, Connection.CloseListener) when 401 HTTP status code is received and the last upgrade request does not contain Authorization header (the last state was not AUTH_UPGRADE_REQUEST_CREATED).

AUTH_UPGRADE_REQUEST_CREATED back to summary

AUTH_UPGRADE_REQUEST_CREATED	back to summary
public static final TyrusClientEngine.TyrusClientEngineState AUTH_UPGRADE_REQUEST_CREATED Upgrade request with Authorization header has been created. Set in `createUpgradeRequest(TimeoutHandler)`.

public static final TyrusClientEngine.TyrusClientEngineState AUTH_UPGRADE_REQUEST_CREATED

Upgrade request with Authorization header has been created.

Set in createUpgradeRequest(TimeoutHandler).

authenticator	back to summary
private volatile Authenticator authenticator

FAILED	back to summary
public static final TyrusClientEngine.TyrusClientEngineState FAILED Handshake failed (final state).

INIT	back to summary
public static final TyrusClientEngine.TyrusClientEngineState INIT Initial state.

REDIRECT_REQUIRED back to summary

REDIRECT_REQUIRED	back to summary
public static final TyrusClientEngine.TyrusClientEngineState REDIRECT_REQUIRED Upgrade request must be redirected. Set in `processResponse(UpgradeResponse, Writer, Connection.CloseListener)` when 3xx HTTP status code is received.

public static final TyrusClientEngine.TyrusClientEngineState REDIRECT_REQUIRED

Upgrade request must be redirected.

Set in processResponse(UpgradeResponse, Writer, Connection.CloseListener) when 3xx HTTP status code is received.

SUCCESS	back to summary
public static final TyrusClientEngine.TyrusClientEngineState SUCCESS Handshake succeeded (final state).

UPGRADE_REQUEST_CREATED back to summary

UPGRADE_REQUEST_CREATED	back to summary
public static final TyrusClientEngine.TyrusClientEngineState UPGRADE_REQUEST_CREATED Upgrade request has been created. Set in `createUpgradeRequest(TimeoutHandler)`.

public static final TyrusClientEngine.TyrusClientEngineState UPGRADE_REQUEST_CREATED

Upgrade request has been created.

Set in createUpgradeRequest(TimeoutHandler).

wwwAuthenticateHeader	back to summary
private volatile String wwwAuthenticateHeader

Constructor Detail

TyrusClientEngineState	back to summary
private TyrusClientEngineState()

Method Detail

getAuthenticator	back to summary
pack-priv Authenticator getAuthenticator()

getWwwAuthenticateHeader	back to summary
pack-priv String getWwwAuthenticateHeader()

setAuthenticator	back to summary
pack-priv void setAuthenticator(Authenticator authenticator)

setWwwAuthenticateHeader	back to summary
pack-priv void setWwwAuthenticateHeader(String wwwAuthenticateHeader)

valueOf	back to summary
public static TyrusClientEngine.TyrusClientEngineState valueOf(String name)

values	back to summary
public static TyrusClientEngine.TyrusClientEngineState[] values()

org.glassfish.tyrus.client back to summary

private Class TyrusClientEngine.TyrusReadHandler

Class Inheritance

extends Object
implements ReadHandler

java.lang.Object
org.glassfish.tyrus.client.TyrusClientEngine.TyrusReadHandler

All Implemented Interfaces

org.glassfish.tyrus.spi.ReadHandler

Field Summary

Modifier and Type	Field and Description
private ByteBuffer	buffer
private final ExtendedExtension.ExtensionContext	extensionContext
private final ProtocolHandler	handler
private final int	incomingBufferSize
private final List<Extension>	negotiatedExtensions
private final TyrusWebSocket	socket

Constructor Summary

Access	Constructor and Description
pack-priv	TyrusReadHandler(final ProtocolHandler protocolHandler, final TyrusWebSocket socket, int incomingBufferSize, List<Extension> negotiatedExtensions, ExtendedExtension.ExtensionContext extensionContext)

Method Summary

Modifier and Type	Method and Description
public void	handle(ByteBuffer websocket data of a connection. data) Implements org.glassfish.tyrus.spi.ReadHandler.handle. A transport reads websocket data and invokes this method to handover websocket data for a connection to tyrus runtime.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

buffer	back to summary
private ByteBuffer buffer

extensionContext	back to summary
private final ExtendedExtension.ExtensionContext extensionContext

handler	back to summary
private final ProtocolHandler handler

incomingBufferSize	back to summary
private final int incomingBufferSize

negotiatedExtensions	back to summary
private final List<Extension> negotiatedExtensions

socket	back to summary
private final TyrusWebSocket socket

Constructor Detail

TyrusReadHandler	back to summary
pack-priv TyrusReadHandler(final ProtocolHandler protocolHandler, final TyrusWebSocket socket, int incomingBufferSize, List<Extension> negotiatedExtensions, ExtendedExtension.ExtensionContext extensionContext)

Method Detail

handle

back to summary

public void handle(ByteBuffer data)

Implements org.glassfish.tyrus.spi.ReadHandler.handle.

Doc from org.glassfish.tyrus.spi.ReadHandler.handle.

A transport reads websocket data and invokes this method to handover websocket data for a connection to tyrus runtime. The runtime consumes as much data as possible from the byte buffer. If there is some remaining data in the buffer, transport needs pass those bytes in more call (along with more data) in the same byte buffer or in a newer byte buffer.

Parameters

data:ByteBuffer: websocket data of a connection.

Annotations

@Override

public Class TyrusClientEngine

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface TyrusClientEngine.ClientHandshakeListener

Method Summary

Method Detail

private final Enum TyrusClientEngine.TyrusClientEngineState

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class TyrusClientEngine.TyrusReadHandler

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail