Class ServerWebSocket
- java.lang.Object
-
- io.vertx.mutiny.core.http.ServerWebSocket
-
- All Implemented Interfaces:
WebSocketBase
,ReadStream<Buffer>
,StreamBase
,WriteStream<Buffer>
public class ServerWebSocket extends Object implements WebSocketBase
Represents a server side WebSocket.Instances of this class are passed into a
NOTE: This class has been automatically generated from theHttpServer.webSocketHandler(java.util.function.Consumer<io.vertx.mutiny.core.http.ServerWebSocket>)
or provided when a WebSocket handshake is manuallyHttpServerRequest.toWebSocket()
ed.original
non Mutiny-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static TypeArg<ServerWebSocket>
__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description ServerWebSocket(io.vertx.core.http.ServerWebSocket delegate)
ServerWebSocket(Object delegate)
-
Method Summary
-
-
-
Field Detail
-
__TYPE_ARG
public static final TypeArg<ServerWebSocket> __TYPE_ARG
-
-
Constructor Detail
-
ServerWebSocket
public ServerWebSocket(io.vertx.core.http.ServerWebSocket delegate)
-
ServerWebSocket
public ServerWebSocket(Object delegate)
-
-
Method Detail
-
getDelegate
public io.vertx.core.http.ServerWebSocket getDelegate()
- Specified by:
getDelegate
in interfaceReadStream<Buffer>
- Specified by:
getDelegate
in interfaceStreamBase
- Specified by:
getDelegate
in interfaceWebSocketBase
- Specified by:
getDelegate
in interfaceWriteStream<Buffer>
-
toSubscriber
@CheckReturnValue public WriteStreamSubscriber<Buffer> toSubscriber()
-
write
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> write(Buffer data)
Same as but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
write
in interfaceWebSocketBase
- Specified by:
write
in interfaceWriteStream<Buffer>
- Parameters:
data
-- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writeAndAwait
public Void writeAndAwait(Buffer data)
Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writeAndAwait
in interfaceWebSocketBase
- Specified by:
writeAndAwait
in interfaceWriteStream<Buffer>
- Parameters:
data
-- Returns:
- the Void instance produced by the operation.
-
writeAndForget
public void writeAndForget(Buffer data)
Variant ofio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
io.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromio.vertx.mutiny.core.streams.WriteStream#write(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
writeAndForget
in interfaceWebSocketBase
- Specified by:
writeAndForget
in interfaceWriteStream<Buffer>
- Parameters:
data
-
-
end
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> end(Buffer data)
Same as but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
end
in interfaceWebSocketBase
- Specified by:
end
in interfaceWriteStream<Buffer>
- Parameters:
data
-- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
endAndAwait
public Void endAndAwait(Buffer data)
Blocking variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
endAndAwait
in interfaceWebSocketBase
- Specified by:
endAndAwait
in interfaceWriteStream<Buffer>
- Parameters:
data
-- Returns:
- the Void instance produced by the operation.
-
endAndForget
public void endAndForget(Buffer data)
Variant ofio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
io.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromio.vertx.mutiny.core.streams.WriteStream#end(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
endAndForget
in interfaceWebSocketBase
- Specified by:
endAndForget
in interfaceWriteStream<Buffer>
- Parameters:
data
-
-
writeQueueFull
public boolean writeQueueFull()
- Specified by:
writeQueueFull
in interfaceWebSocketBase
- Specified by:
writeQueueFull
in interfaceWriteStream<Buffer>
- Returns:
true
if write queue is full
-
pipe
public Pipe<Buffer> pipe()
- Specified by:
pipe
in interfaceReadStream<Buffer>
- Specified by:
pipe
in interfaceWebSocketBase
- Returns:
- a pipe
-
pipeTo
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> pipeTo(WriteStream<Buffer> dst)
Pipe thisReadStream
to theWriteStream
.Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the
handler
will be called with the result.Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
pipeTo
in interfaceReadStream<Buffer>
- Specified by:
pipeTo
in interfaceWebSocketBase
- Parameters:
dst
- the destination write stream- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
pipeToAndAwait
public Void pipeToAndAwait(WriteStream<Buffer> dst)
Blocking variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
pipeToAndAwait
in interfaceReadStream<Buffer>
- Specified by:
pipeToAndAwait
in interfaceWebSocketBase
- Parameters:
dst
- the destination write stream- Returns:
- the Void instance produced by the operation.
-
pipeToAndForget
public void pipeToAndForget(WriteStream<Buffer> dst)
Variant ofReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
that ignores the result of the operation.This method subscribes on the result of
ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)
but you don't need to compose it with other operations.- Specified by:
pipeToAndForget
in interfaceReadStream<Buffer>
- Specified by:
pipeToAndForget
in interfaceWebSocketBase
- Parameters:
dst
- the destination write stream
-
binaryHandlerID
public String binaryHandlerID()
- Specified by:
binaryHandlerID
in interfaceWebSocketBase
- Returns:
- the binary handler id
-
textHandlerID
public String textHandlerID()
- Specified by:
textHandlerID
in interfaceWebSocketBase
- Returns:
- the text handler id
-
subProtocol
public String subProtocol()
- Specified by:
subProtocol
in interfaceWebSocketBase
- Returns:
-
closeStatusCode
public Short closeStatusCode()
- Specified by:
closeStatusCode
in interfaceWebSocketBase
- Returns:
-
closeReason
public String closeReason()
- Specified by:
closeReason
in interfaceWebSocketBase
- Returns:
-
headers
public MultiMap headers()
- Specified by:
headers
in interfaceWebSocketBase
- Returns:
- the headers
-
textMessageHandler
public WebSocketBase textMessageHandler(Consumer<String> handler)
- Specified by:
textMessageHandler
in interfaceWebSocketBase
- Parameters:
handler
- the handler- Returns:
-
binaryMessageHandler
public WebSocketBase binaryMessageHandler(Consumer<Buffer> handler)
- Specified by:
binaryMessageHandler
in interfaceWebSocketBase
- Parameters:
handler
- the handler- Returns:
-
pongHandler
public WebSocketBase pongHandler(Consumer<Buffer> handler)
- Specified by:
pongHandler
in interfaceWebSocketBase
- Parameters:
handler
- the handler- Returns:
-
end
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> end()
CallsWebSocketBase.close()
Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
end
in interfaceWebSocketBase
- Specified by:
end
in interfaceWriteStream<Buffer>
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
endAndAwait
public Void endAndAwait()
Blocking variant ofWebSocketBase.end(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
endAndAwait
in interfaceWebSocketBase
- Specified by:
endAndAwait
in interfaceWriteStream<Buffer>
- Returns:
- the Void instance produced by the operation.
-
endAndForget
public void endAndForget()
Variant ofWebSocketBase.end(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.end(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.end(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
endAndForget
in interfaceWebSocketBase
- Specified by:
endAndForget
in interfaceWriteStream<Buffer>
-
close
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> close()
Same asclose()
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
close
in interfaceWebSocketBase
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
closeAndAwait
public Void closeAndAwait()
Blocking variant ofWebSocketBase.close()
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
closeAndAwait
in interfaceWebSocketBase
- Returns:
- the Void instance produced by the operation.
-
closeAndForget
public void closeAndForget()
Variant ofWebSocketBase.close()
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.close()
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.close()
but you don't need to compose it with other operations.- Specified by:
closeAndForget
in interfaceWebSocketBase
-
close
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> close(short statusCode)
Same asWebSocketBase.close()
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
close
in interfaceWebSocketBase
- Parameters:
statusCode
-- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
closeAndAwait
public Void closeAndAwait(short statusCode)
Blocking variant ofWebSocketBase.close(short)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
closeAndAwait
in interfaceWebSocketBase
- Parameters:
statusCode
-- Returns:
- the Void instance produced by the operation.
-
closeAndForget
public void closeAndForget(short statusCode)
Variant ofWebSocketBase.close(short)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.close(short)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.close(short)
but you don't need to compose it with other operations.- Specified by:
closeAndForget
in interfaceWebSocketBase
- Parameters:
statusCode
-
-
close
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> close(short statusCode, String reason)
Same asWebSocketBase.close()
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
close
in interfaceWebSocketBase
- Parameters:
statusCode
-reason
-- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
closeAndAwait
public Void closeAndAwait(short statusCode, String reason)
Blocking variant ofWebSocketBase.close(short,String)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
closeAndAwait
in interfaceWebSocketBase
- Parameters:
statusCode
-reason
-- Returns:
- the Void instance produced by the operation.
-
closeAndForget
public void closeAndForget(short statusCode, String reason)
Variant ofWebSocketBase.close(short,String)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.close(short,String)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.close(short,String)
but you don't need to compose it with other operations.- Specified by:
closeAndForget
in interfaceWebSocketBase
- Parameters:
statusCode
-reason
-
-
remoteAddress
public SocketAddress remoteAddress()
- Specified by:
remoteAddress
in interfaceWebSocketBase
- Returns:
- the remote address for this connection, possibly
null
(e.g a server bound on a domain socket). IfuseProxyProtocol
is set totrue
, the address returned will be of the actual connecting client.
-
localAddress
public SocketAddress localAddress()
- Specified by:
localAddress
in interfaceWebSocketBase
- Returns:
- the local address for this connection, possibly
null
(e.g a server bound on a domain socket) IfuseProxyProtocol
is set totrue
, the address returned will be of the proxy.
-
isSsl
public boolean isSsl()
- Specified by:
isSsl
in interfaceWebSocketBase
- Returns:
- true if this
HttpConnection
is encrypted via SSL/TLS.
-
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interfaceWebSocketBase
- Returns:
true
if the WebSocket is closed
-
exceptionHandler
public ServerWebSocket exceptionHandler(Consumer<Throwable> handler)
- Specified by:
exceptionHandler
in interfaceReadStream<Buffer>
- Specified by:
exceptionHandler
in interfaceStreamBase
- Specified by:
exceptionHandler
in interfaceWebSocketBase
- Specified by:
exceptionHandler
in interfaceWriteStream<Buffer>
- Parameters:
handler
- the exception handler- Returns:
-
handler
public ServerWebSocket handler(Consumer<Buffer> handler)
- Specified by:
handler
in interfaceReadStream<Buffer>
- Specified by:
handler
in interfaceWebSocketBase
- Returns:
-
pause
public ServerWebSocket pause()
- Specified by:
pause
in interfaceReadStream<Buffer>
- Specified by:
pause
in interfaceWebSocketBase
- Returns:
- a reference to this, so the API can be used fluently
-
resume
public ServerWebSocket resume()
- Specified by:
resume
in interfaceReadStream<Buffer>
- Specified by:
resume
in interfaceWebSocketBase
- Returns:
- a reference to this, so the API can be used fluently
-
fetch
public ServerWebSocket fetch(long amount)
- Specified by:
fetch
in interfaceReadStream<Buffer>
- Specified by:
fetch
in interfaceWebSocketBase
- Returns:
- a reference to this, so the API can be used fluently
-
endHandler
public ServerWebSocket endHandler(Runnable endHandler)
- Specified by:
endHandler
in interfaceReadStream<Buffer>
- Specified by:
endHandler
in interfaceWebSocketBase
- Returns:
-
setWriteQueueMaxSize
public ServerWebSocket setWriteQueueMaxSize(int maxSize)
- Specified by:
setWriteQueueMaxSize
in interfaceWebSocketBase
- Specified by:
setWriteQueueMaxSize
in interfaceWriteStream<Buffer>
- Parameters:
maxSize
- the max size of the write stream- Returns:
- a reference to this, so the API can be used fluently
-
drainHandler
public ServerWebSocket drainHandler(Runnable handler)
- Specified by:
drainHandler
in interfaceWebSocketBase
- Specified by:
drainHandler
in interfaceWriteStream<Buffer>
- Parameters:
handler
- the handler- Returns:
-
writeFrame
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writeFrame(WebSocketFrame frame)
Description copied from interface:WebSocketBase
Same asWebSocketBase.writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writeFrame
in interfaceWebSocketBase
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writeFrameAndAwait
public Void writeFrameAndAwait(WebSocketFrame frame)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writeFrameAndAwait
in interfaceWebSocketBase
- Returns:
- the Void instance produced by the operation.
-
writeFrameAndForget
public ServerWebSocket writeFrameAndForget(WebSocketFrame frame)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writeFrame(io.vertx.mutiny.core.http.WebSocketFrame)
but you don't need to compose it with other operations.- Specified by:
writeFrameAndForget
in interfaceWebSocketBase
- Returns:
- the instance of WebSocketBase to chain method calls.
-
writeFinalTextFrame
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writeFinalTextFrame(String text)
Description copied from interface:WebSocketBase
Same asWebSocketBase.writeFinalTextFrame(java.lang.String)
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writeFinalTextFrame
in interfaceWebSocketBase
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writeFinalTextFrameAndAwait
public Void writeFinalTextFrameAndAwait(String text)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writeFinalTextFrame(String)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writeFinalTextFrameAndAwait
in interfaceWebSocketBase
- Returns:
- the Void instance produced by the operation.
-
writeFinalTextFrameAndForget
public ServerWebSocket writeFinalTextFrameAndForget(String text)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writeFinalTextFrame(String)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writeFinalTextFrame(String)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writeFinalTextFrame(String)
but you don't need to compose it with other operations.- Specified by:
writeFinalTextFrameAndForget
in interfaceWebSocketBase
- Returns:
- the instance of WebSocketBase to chain method calls.
-
writeFinalBinaryFrame
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writeFinalBinaryFrame(Buffer data)
Description copied from interface:WebSocketBase
Same asWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writeFinalBinaryFrame
in interfaceWebSocketBase
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writeFinalBinaryFrameAndAwait
public Void writeFinalBinaryFrameAndAwait(Buffer data)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writeFinalBinaryFrameAndAwait
in interfaceWebSocketBase
- Returns:
- the Void instance produced by the operation.
-
writeFinalBinaryFrameAndForget
public ServerWebSocket writeFinalBinaryFrameAndForget(Buffer data)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writeFinalBinaryFrame(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
writeFinalBinaryFrameAndForget
in interfaceWebSocketBase
- Returns:
- the instance of WebSocketBase to chain method calls.
-
writeBinaryMessage
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writeBinaryMessage(Buffer data)
Description copied from interface:WebSocketBase
Same asWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writeBinaryMessage
in interfaceWebSocketBase
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writeBinaryMessageAndAwait
public Void writeBinaryMessageAndAwait(Buffer data)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writeBinaryMessageAndAwait
in interfaceWebSocketBase
- Returns:
- the Void instance produced by the operation.
-
writeBinaryMessageAndForget
public ServerWebSocket writeBinaryMessageAndForget(Buffer data)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writeBinaryMessage(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
writeBinaryMessageAndForget
in interfaceWebSocketBase
- Returns:
- the instance of WebSocketBase to chain method calls.
-
writeTextMessage
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writeTextMessage(String text)
Description copied from interface:WebSocketBase
Same asWebSocketBase.writeTextMessage(java.lang.String)
but with anhandler
called when the operation completesUnlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writeTextMessage
in interfaceWebSocketBase
- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writeTextMessageAndAwait
public Void writeTextMessageAndAwait(String text)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writeTextMessage(String)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writeTextMessageAndAwait
in interfaceWebSocketBase
- Returns:
- the Void instance produced by the operation.
-
writeTextMessageAndForget
public ServerWebSocket writeTextMessageAndForget(String text)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writeTextMessage(String)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writeTextMessage(String)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writeTextMessage(String)
but you don't need to compose it with other operations.- Specified by:
writeTextMessageAndForget
in interfaceWebSocketBase
- Returns:
- the instance of WebSocketBase to chain method calls.
-
writePing
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writePing(Buffer data)
Description copied from interface:WebSocketBase
Writes a ping frame to the connection. This will be written in a single frame. Ping frames may be at most 125 bytes (octets).This method should not be used to write application data and should only be used for implementing a keep alive or to ensure the client is still responsive, see RFC 6455 Section section 5.5.2.
There is no handler for ping frames because RFC 6455 clearly states that the only response to a ping frame is a pong frame with identical contents.
Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writePing
in interfaceWebSocketBase
- Parameters:
data
- the data to write, may be at most 125 bytes- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writePingAndAwait
public Void writePingAndAwait(Buffer data)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writePing(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writePingAndAwait
in interfaceWebSocketBase
- Parameters:
data
- the data to write, may be at most 125 bytes- Returns:
- the Void instance produced by the operation.
-
writePingAndForget
public ServerWebSocket writePingAndForget(Buffer data)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writePing(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writePing(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writePing(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
writePingAndForget
in interfaceWebSocketBase
- Parameters:
data
- the data to write, may be at most 125 bytes- Returns:
- the instance of WebSocketBase to chain method calls.
-
writePong
@CheckReturnValue public io.smallrye.mutiny.Uni<Void> writePong(Buffer data)
Description copied from interface:WebSocketBase
Writes a pong frame to the connection. This will be written in a single frame. Pong frames may be at most 125 bytes (octets).This method should not be used to write application data and should only be used for implementing a keep alive or to ensure the client is still responsive, see RFC 6455 section 5.5.2.
There is no need to manually write a pong frame, as the server and client both handle responding to a ping from with a pong from automatically and this is exposed to users. RFC 6455 section 5.5.3 states that pongs may be sent unsolicited in order to implement a one way heartbeat.
Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Specified by:
writePong
in interfaceWebSocketBase
- Parameters:
data
- the data to write, may be at most 125 bytes- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
-
writePongAndAwait
public Void writePongAndAwait(Buffer data)
Description copied from interface:WebSocketBase
Blocking variant ofWebSocketBase.writePong(io.vertx.mutiny.core.buffer.Buffer)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Specified by:
writePongAndAwait
in interfaceWebSocketBase
- Parameters:
data
- the data to write, may be at most 125 bytes- Returns:
- the Void instance produced by the operation.
-
writePongAndForget
public ServerWebSocket writePongAndForget(Buffer data)
Description copied from interface:WebSocketBase
Variant ofWebSocketBase.writePong(io.vertx.mutiny.core.buffer.Buffer)
that ignores the result of the operation.This method subscribes on the result of
WebSocketBase.writePong(io.vertx.mutiny.core.buffer.Buffer)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromWebSocketBase.writePong(io.vertx.mutiny.core.buffer.Buffer)
but you don't need to compose it with other operations.- Specified by:
writePongAndForget
in interfaceWebSocketBase
- Parameters:
data
- the data to write, may be at most 125 bytes- Returns:
- the instance of WebSocketBase to chain method calls.
-
closeHandler
public ServerWebSocket closeHandler(Runnable handler)
- Specified by:
closeHandler
in interfaceWebSocketBase
- Parameters:
handler
- the handler- Returns:
-
frameHandler
public ServerWebSocket frameHandler(Consumer<WebSocketFrame> handler)
- Specified by:
frameHandler
in interfaceWebSocketBase
- Parameters:
handler
- the handler- Returns:
-
scheme
public String scheme()
- Returns:
- the WebSocket handshake scheme
-
host
@Deprecated public String host()
Deprecated.useauthority()
instead- Returns:
- the WebSocket handshake host
-
authority
public HostAndPort authority()
- Returns:
- the WebSocket handshake authority
-
uri
public String uri()
-
path
public String path()
- Returns:
- the WebSocket handshake path.
-
query
public String query()
- Returns:
- the WebSocket handshake query string.
-
accept
@Deprecated public void accept()
Deprecated.instead useServerWebSocketHandshake.accept()
-
reject
@Deprecated public void reject()
Deprecated.instead useServerWebSocketHandshake.reject()
-
reject
@Deprecated public void reject(int status)
Deprecated.instead useServerWebSocketHandshake.reject(int)
- Parameters:
status
-
-
setHandshake
@CheckReturnValue @Deprecated public io.smallrye.mutiny.Uni<Integer> setHandshake(io.smallrye.mutiny.Uni<Integer> future)
Deprecated.instead useServerWebSocketHandshake
Set an asynchronous result for the handshake, upon completion of the specifiedfuture
, the WebSocket will either be- accepted when the
future
succeeds with the HTTP status code - rejected when the
future
is succeeds with an HTTP status code different than - rejected when the
future
fails with the HTTP status code500
close()
method will try to accept the handshake and close the WebSocket afterward. Thus it is advised to try to complete thefuture
with or .This method should be called from the WebSocket handler to explicitly set an asynchronous handshake.
Calling this method will override the
future
completion handler.Unlike the bare Vert.x variant, this method returns a
Uni
. Don't forget to subscribe on it to trigger the operation.- Parameters:
future
- the future to complete with- Returns:
- the
uni
firing the result of the operation when completed, or a failure if the operation failed.
- accepted when the
-
setHandshakeAndAwait
@Deprecated public Integer setHandshakeAndAwait(io.smallrye.mutiny.Uni<Integer> future)
Deprecated.instead useServerWebSocketHandshake
Blocking variant ofio.vertx.mutiny.core.http.ServerWebSocket#setHandshake(Future)
.This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).
- Parameters:
future
- the future to complete with- Returns:
- the Integer instance produced by the operation.
-
setHandshakeAndForget
@Deprecated public void setHandshakeAndForget(io.smallrye.mutiny.Uni<Integer> future)
Deprecated.instead useServerWebSocketHandshake
Variant ofio.vertx.mutiny.core.http.ServerWebSocket#setHandshake(Future)
that ignores the result of the operation.This method subscribes on the result of
io.vertx.mutiny.core.http.ServerWebSocket#setHandshake(Future)
, but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation fromio.vertx.mutiny.core.http.ServerWebSocket#setHandshake(Future)
but you don't need to compose it with other operations.- Parameters:
future
- the future to complete with
-
sslSession
public SSLSession sslSession()
- Specified by:
sslSession
in interfaceWebSocketBase
- Returns:
- SSLSession associated with the underlying socket. Returns null if connection is not SSL.
-
toMulti
@CheckReturnValue public io.smallrye.mutiny.Multi<Buffer> toMulti()
- Specified by:
toMulti
in interfaceReadStream<Buffer>
-
newInstance
public static ServerWebSocket newInstance(io.vertx.core.http.ServerWebSocket arg)
-
-