org.apache.hc.client5.http.websocket.transport

Class WebSocketUpgrader

java.lang.Object

org.apache.hc.client5.http.websocket.transport.WebSocketUpgrader

All Implemented Interfaces:

ProtocolUpgradeHandler

@Internal
public final class WebSocketUpgrader
extends Object
implements ProtocolUpgradeHandler

Bridges HttpCore protocol upgrade to a WebSocket WebSocketIoHandler.

IMPORTANT: This class does NOT call WebSocketListener.onOpen(WebSocket). The caller performs notification after switchProtocol(...) completes.

Constructor Summary

Constructors

Constructor and Description
WebSocketUpgrader(WebSocketListener listener, WebSocketClientConfig cfg, ExtensionChain chain)
WebSocketUpgrader(WebSocketListener listener, WebSocketClientConfig cfg, ExtensionChain chain, AsyncClientEndpoint endpoint)

Method Summary

Modifier and Type	Method and Description
WebSocket	getWebSocket() Returns the WebSocket created during upgrade(org.apache.hc.core5.reactor.ProtocolIOSession, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.ProtocolIOSession>).
void	upgrade(ProtocolIOSession ioSession, FutureCallback<ProtocolIOSession> callback)

Methods inherited from class java.lang.Object

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

Constructor Detail

WebSocketUpgrader

public WebSocketUpgrader(WebSocketListener listener,
                         WebSocketClientConfig cfg,
                         ExtensionChain chain)

WebSocketUpgrader

public WebSocketUpgrader(WebSocketListener listener,
                         WebSocketClientConfig cfg,
                         ExtensionChain chain,
                         AsyncClientEndpoint endpoint)

Method Detail

getWebSocket

public WebSocket getWebSocket()

Returns the WebSocket created during upgrade(org.apache.hc.core5.reactor.ProtocolIOSession, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.ProtocolIOSession>).

upgrade

public void upgrade(ProtocolIOSession ioSession,
                    FutureCallback<ProtocolIOSession> callback)

Specified by:

upgrade in interface ProtocolUpgradeHandler