@Internal public class DefaultWebSocketHttpResponse extends io.netty.handler.codec.http.DefaultHttpResponse implements WebSocketHttpResponse
Constructor and Description |
---|
DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version,
io.netty.handler.codec.http.HttpResponseStatus status,
boolean validateHeaders,
Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor,
io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory) |
DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version,
io.netty.handler.codec.http.HttpResponseStatus status,
Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor,
io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory) |
Modifier and Type | Method and Description |
---|---|
io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory |
handshakerFactory()
Get the handshaker factory to use to reconfigure the channel.
|
void |
onComplete() |
void |
onError(Throwable error) |
void |
onNext(io.netty.handler.codec.http.websocketx.WebSocketFrame webSocketFrame) |
void |
onSubscribe(Subscription subscription) |
void |
subscribe(Subscriber<? super io.netty.handler.codec.http.websocketx.WebSocketFrame> subscriber) |
equals, getStatus, hashCode, setProtocolVersion, setStatus, status, toString
getProtocolVersion, headers, protocolVersion
decoderResult, getDecoderResult, setDecoderResult
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getStatus, setProtocolVersion, setStatus, status
public DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version, io.netty.handler.codec.http.HttpResponseStatus status, Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor, io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory)
version
- The Http versionstatus
- The Http response statusprocessor
- The Processor
handshakerFactory
- The WebSocketServerHandshakerFactory
public DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version, io.netty.handler.codec.http.HttpResponseStatus status, boolean validateHeaders, Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor, io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory)
version
- The Http versionvalidateHeaders
- Whether to validate the headersstatus
- The Http response statusprocessor
- The Processor
handshakerFactory
- The WebSocketServerHandshakerFactory
public io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory()
WebSocketHttpResponse
handshakerFactory
in interface WebSocketHttpResponse
public void subscribe(Subscriber<? super io.netty.handler.codec.http.websocketx.WebSocketFrame> subscriber)
public void onSubscribe(Subscription subscription)
onSubscribe
in interface Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>
public void onNext(io.netty.handler.codec.http.websocketx.WebSocketFrame webSocketFrame)
onNext
in interface Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>
public void onError(Throwable error)
onError
in interface Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>
public void onComplete()
onComplete
in interface Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>