public interface WebsocketOutbound extends NettyOutbound
| Modifier and Type | Field and Description |
|---|---|
static Function<? super io.netty.buffer.ByteBuf,? extends io.netty.handler.codec.http.websocketx.WebSocketFrame> |
bytebufToWebsocketFrame |
static Function<? super String,? extends io.netty.handler.codec.http.websocketx.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 io.netty.buffer.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, withConnectionstatic final Function<? super String,? extends io.netty.handler.codec.http.websocketx.WebSocketFrame> stringToWebsocketFrame
static final Function<? super io.netty.buffer.ByteBuf,? extends io.netty.handler.codec.http.websocketx.WebSocketFrame> bytebufToWebsocketFrame
@Nullable String selectedSubprotocol()
NettyOutbound send(Publisher<? extends io.netty.buffer.ByteBuf> dataStream)
NettyOutboundA new NettyOutbound type (or the same) for typed send
sequences.
Note: Nesting any send* method is not supported.
send in interface NettyOutbounddataStream - 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)
NettyOutboundNote: Nesting any send* method is not supported.
sendString in interface NettyOutbounddataStream - the dataStream publishing Buffer items to write on this channelcharset - the encoding charset