Uses of Interface
io.quarkus.websockets.next.WebSocketClientConnection

Packages that use WebSocketClientConnection

Package	Description
io.quarkus.websockets.next
io.quarkus.websockets.next.runtime

Uses of WebSocketClientConnection in io.quarkus.websockets.next

Methods in io.quarkus.websockets.next that return WebSocketClientConnection

Modifier and Type	Method	Description
default WebSocketClientConnection	BasicWebSocketConnector.connectAndAwait()
default WebSocketClientConnection	WebSocketConnector.connectAndAwait()

Methods in io.quarkus.websockets.next that return types with arguments of type WebSocketClientConnection

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<WebSocketClientConnection>	BasicWebSocketConnector.connect()
io.smallrye.mutiny.Uni<WebSocketClientConnection>	WebSocketConnector.connect()
default Collection<WebSocketClientConnection>	OpenClientConnections.findByClientId(String clientId)	Returns an immutable snapshot of all open connections for the given client id.
default Optional<WebSocketClientConnection>	OpenClientConnections.findByConnectionId(String connectionId)	Returns the open connection with the given id.
default Collection<WebSocketClientConnection>	OpenClientConnections.listAll()	Returns an immutable snapshot of all open connections at the given time.
Stream<WebSocketClientConnection>	OpenClientConnections.stream()	Returns the stream of all open connections at the given time.

Method parameters in io.quarkus.websockets.next with type arguments of type WebSocketClientConnection

Modifier and Type	Method	Description
BasicWebSocketConnector	BasicWebSocketConnector.onBinaryMessage(BiConsumer<WebSocketClientConnection,io.vertx.core.buffer.Buffer> consumer)	Set a callback to be invoked when a binary message is received from the server.
BasicWebSocketConnector	BasicWebSocketConnector.onClose(BiConsumer<WebSocketClientConnection,CloseReason> consumer)	Set a callback to be invoked when a connection to the server is closed.
BasicWebSocketConnector	BasicWebSocketConnector.onError(BiConsumer<WebSocketClientConnection,Throwable> consumer)	Set a callback to be invoked when an error occurs.
BasicWebSocketConnector	BasicWebSocketConnector.onOpen(Consumer<WebSocketClientConnection> consumer)	Set a callback to be invoked when a connection to the server is open.
BasicWebSocketConnector	BasicWebSocketConnector.onPing(BiConsumer<WebSocketClientConnection,io.vertx.core.buffer.Buffer> consumer)	Set a callback to be invoked when a ping message is received from the server.
BasicWebSocketConnector	BasicWebSocketConnector.onPong(BiConsumer<WebSocketClientConnection,io.vertx.core.buffer.Buffer> consumer)	Set a callback to be invoked when a pong message is received from the server.
BasicWebSocketConnector	BasicWebSocketConnector.onTextMessage(BiConsumer<WebSocketClientConnection,String> consumer)	Set a callback to be invoked when a text message is received from the server.

Uses of WebSocketClientConnection in io.quarkus.websockets.next.runtime

Classes in io.quarkus.websockets.next.runtime that implement WebSocketClientConnection

Modifier and Type	Class	Description
(package private) class	WebSocketClientConnectionImpl

Methods in io.quarkus.websockets.next.runtime that return types with arguments of type WebSocketClientConnection

Modifier and Type	Method	Description
Consumer<WebSocketClientConnection>	WebSocketConnectorBase.WebSocketOpen.cleanup()	Returns the value of the cleanup record component.
io.smallrye.mutiny.Uni<WebSocketClientConnection>	BasicWebSocketConnectorImpl.connect()
io.smallrye.mutiny.Uni<WebSocketClientConnection>	WebSocketConnectorImpl.connect()
Iterator<WebSocketClientConnection>	ClientConnectionManager.iterator()
(package private) Consumer<WebSocketClientConnection>	WebSocketConnectorBase.newCleanupConsumer(io.vertx.core.http.WebSocketClient client, io.vertx.core.impl.ContextImpl context)
Stream<WebSocketClientConnection>	ClientConnectionManager.stream()

Methods in io.quarkus.websockets.next.runtime with parameters of type WebSocketClientConnection

Modifier and Type	Method	Description
void	ClientConnectionManager.ClientConnectionListener.connectionAdded(String endpoint, WebSocketClientConnection connection)

Method parameters in io.quarkus.websockets.next.runtime with type arguments of type WebSocketClientConnection

Modifier and Type	Method	Description
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onBinaryMessage(BiConsumer<WebSocketClientConnection,io.vertx.core.buffer.Buffer> consumer)
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onClose(BiConsumer<WebSocketClientConnection,CloseReason> consumer)
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onError(BiConsumer<WebSocketClientConnection,Throwable> consumer)
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onOpen(Consumer<WebSocketClientConnection> consumer)
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onPing(BiConsumer<WebSocketClientConnection,io.vertx.core.buffer.Buffer> consumer)
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onPong(BiConsumer<WebSocketClientConnection,io.vertx.core.buffer.Buffer> consumer)
BasicWebSocketConnector	BasicWebSocketConnectorImpl.onTextMessage(BiConsumer<WebSocketClientConnection,String> consumer)

Constructor parameters in io.quarkus.websockets.next.runtime with type arguments of type WebSocketClientConnection

Modifier	Constructor	Description
(package private)	ClientConnectionManager(jakarta.enterprise.event.Event<WebSocketClientConnection> openEvent, jakarta.enterprise.event.Event<WebSocketClientConnection> closedEvent)
(package private)	WebSocketClientConnectionImpl(String clientId, io.vertx.core.http.WebSocket webSocket, Codecs codecs, Map<String,String> pathParams, URI serverEndpointUri, Map<String,List<String>> headers, TrafficLogger trafficLogger, Map<String,Object> userData, SendingInterceptor sendingInterceptor, Consumer<WebSocketClientConnection> cleanup)
(package private)	WebSocketOpen(Consumer<WebSocketClientConnection> cleanup, io.vertx.core.http.WebSocket websocket)	Creates an instance of a WebSocketOpen record class.