public interface WebsocketOutbound extends NettyOutbound
Modifier and Type | Field and Description |
---|---|
static Function<? super ByteBuf,? extends WebSocketFrame> |
bytebufToWebsocketFrame |
static Function<? super String,? extends WebSocketFrame> |
stringToWebsocketFrame |
Modifier and Type | Method and Description |
---|---|
String |
selectedSubprotocol()
Returns the websocket subprotocol negotiated by the client and server during
the websocket handshake, or null if none was requested.
|
NettyOutbound |
send(Publisher<? extends ByteBuf> dataStream)
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
|
Mono<Void> |
sendClose()
Prepare to send a close frame on subscribe then close the underlying channel.
|
Mono<Void> |
sendClose(int rsv)
Prepare to send a close frame on subscribe then close the underlying channel.
|
Mono<Void> |
sendClose(int rsv,
int statusCode,
String reasonText)
Prepare to send a close frame on subscribe then close the underlying channel.
|
Mono<Void> |
sendClose(int statusCode,
String reasonText)
Prepare to send a close frame on subscribe then close the underlying channel.
|
default NettyOutbound |
sendString(Publisher<? extends String> dataStream,
Charset charset)
Sends String to the peer, listens for any error on write and closes on terminal signal
(complete|error).
|
alloc, neverComplete, send, sendByteArray, sendFile, sendFile, sendFileChunked, sendGroups, sendObject, sendObject, sendObject, sendString, sendUsing, subscribe, then, then, then, withConnection
static final Function<? super String,? extends WebSocketFrame> stringToWebsocketFrame
static final Function<? super ByteBuf,? extends WebSocketFrame> bytebufToWebsocketFrame
@Nullable String selectedSubprotocol()
NettyOutbound send(Publisher<? extends ByteBuf> dataStream)
NettyOutbound
A new NettyOutbound
type (or the same) for typed send
sequences.
Note: Nesting any send* method is not supported.
send
in interface NettyOutbound
dataStream
- the dataStream publishing OUT items to write on this channelNettyOutbound
to append further send. It will emit a complete
signal successful sequence write (e.g. after "flush") or any error during write.Mono<Void> sendClose()
Mono
fulfilled when the send succeeded or failed, immediately
completed if already closedMono<Void> sendClose(int rsv)
rsv
- reserved bits used for protocol extensionsMono
fulfilled when the send succeeded or failed, immediately
completed if already closedMono<Void> sendClose(int statusCode, @Nullable String reasonText)
statusCode
- Integer status code as per RFC 6455#section-7.4. For
example, 1000 indicates normal closure.reasonText
- Reason text. Set to null if no text.Mono
fulfilled when the send succeeded or failed, immediately
completed if already closedIllegalArgumentException
- when the status code MUST NOT be set as a status code in a
Close control frame.
Consider checking RFC 6455#section-7.4
for a complete list of the close status codes.Mono<Void> sendClose(int rsv, int statusCode, @Nullable String reasonText)
rsv
- reserved bits used for protocol extensionsstatusCode
- Integer status code as per RFC 6455#section-7.4. For
example, 1000 indicates normal closure.reasonText
- Reason text. Set to null if no text.Mono
fulfilled when the send succeeded or failed, immediately
completed if already closedIllegalArgumentException
- when the status code MUST NOT be set as a status code in a
Close control frame.
Consider checking RFC 6455#section-7.4
for a complete list of the close status codes.default NettyOutbound sendString(Publisher<? extends String> dataStream, Charset charset)
NettyOutbound
Note: Nesting any send* method is not supported.
sendString
in interface NettyOutbound
dataStream
- the dataStream publishing Buffer items to write on this channelcharset
- the encoding charset