io.micronaut.http.netty.stream

Class DefaultWebSocketHttpResponse

java.lang.Object

io.netty.handler.codec.http.DefaultHttpObject

io.netty.handler.codec.http.DefaultHttpMessage

io.netty.handler.codec.http.DefaultHttpResponse

io.micronaut.http.netty.stream.DefaultWebSocketHttpResponse

All Implemented Interfaces:

WebSocketHttpResponse, io.netty.handler.codec.DecoderResultProvider, io.netty.handler.codec.http.HttpMessage, io.netty.handler.codec.http.HttpObject, io.netty.handler.codec.http.HttpResponse, org.reactivestreams.Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame>, org.reactivestreams.Publisher<io.netty.handler.codec.http.websocketx.WebSocketFrame>, org.reactivestreams.Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>

@Internal
public class DefaultWebSocketHttpResponse
extends io.netty.handler.codec.http.DefaultHttpResponse
implements WebSocketHttpResponse

A default WebSocket HTTP response.

Since:

1.0

Author:

jroper, Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version, io.netty.handler.codec.http.HttpResponseStatus status, boolean validateHeaders, org.reactivestreams.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, org.reactivestreams.Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor, io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory)

Method Summary

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(java.lang.Throwable error)
void	onNext(io.netty.handler.codec.http.websocketx.WebSocketFrame webSocketFrame)
void	onSubscribe(org.reactivestreams.Subscription subscription)
void	subscribe(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.websocketx.WebSocketFrame> subscriber)

Methods inherited from class io.netty.handler.codec.http.DefaultHttpResponse

equals, getStatus, hashCode, setProtocolVersion, setStatus, status, toString

Methods inherited from class io.netty.handler.codec.http.DefaultHttpMessage

getProtocolVersion, headers, protocolVersion

Methods inherited from class io.netty.handler.codec.http.DefaultHttpObject

decoderResult, getDecoderResult, setDecoderResult

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.handler.codec.http.HttpResponse

getStatus, setProtocolVersion, setStatus, status

Methods inherited from interface io.netty.handler.codec.http.HttpMessage

getProtocolVersion, headers, protocolVersion

Methods inherited from interface io.netty.handler.codec.http.HttpObject

getDecoderResult

Methods inherited from interface io.netty.handler.codec.DecoderResultProvider

decoderResult, setDecoderResult

Constructor Detail

DefaultWebSocketHttpResponse

public DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version,
                                    io.netty.handler.codec.http.HttpResponseStatus status,
                                    org.reactivestreams.Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor,
                                    io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory)

Parameters:

version - The Http version

status - The Http response status

processor - The Processor

handshakerFactory - The WebSocketServerHandshakerFactory

DefaultWebSocketHttpResponse

public DefaultWebSocketHttpResponse(io.netty.handler.codec.http.HttpVersion version,
                                    io.netty.handler.codec.http.HttpResponseStatus status,
                                    boolean validateHeaders,
                                    org.reactivestreams.Processor<io.netty.handler.codec.http.websocketx.WebSocketFrame,io.netty.handler.codec.http.websocketx.WebSocketFrame> processor,
                                    io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory)

Parameters:

version - The Http version

validateHeaders - Whether to validate the headers

status - The Http response status

processor - The Processor

handshakerFactory - The WebSocketServerHandshakerFactory

Method Detail

handshakerFactory

public io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory handshakerFactory()

Description copied from interface: WebSocketHttpResponse

Get the handshaker factory to use to reconfigure the channel.

Specified by:

handshakerFactory in interface WebSocketHttpResponse

Returns:

The handshaker factory.

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.websocketx.WebSocketFrame> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<io.netty.handler.codec.http.websocketx.WebSocketFrame>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>

onNext

public void onNext(io.netty.handler.codec.http.websocketx.WebSocketFrame webSocketFrame)

Specified by:

onNext in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>

onError

public void onError(java.lang.Throwable error)

Specified by:

onError in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<io.netty.handler.codec.http.websocketx.WebSocketFrame>