reactor.netty.http.server

Class HttpToH2Operations

java.lang.Object

io.netty.util.concurrent.AbstractFuture<V>

io.netty.util.concurrent.DefaultPromise<Void>

reactor.netty.channel.ChannelOperations<INBOUND,OUTBOUND>

reactor.netty.http.HttpOperations<HttpServerRequest,HttpServerResponse>

reactor.netty.http.server.HttpToH2Operations

All Implemented Interfaces:

ChannelFuture, ChannelPromise, Promise<Void>, Future<Void>, Publisher<Void>, Subscriber<Void>, CoreSubscriber<Void>, Disposable, Connection, DisposableChannel, HttpInfos, HttpServerRequest, HttpServerResponse, NettyInbound, NettyOutbound

public class HttpToH2Operations
extends HttpOperations<HttpServerRequest,HttpServerResponse>

Author:

Stephane Maldini

Nested Class Summary

Nested classes/interfaces inherited from class reactor.netty.channel.ChannelOperations

ChannelOperations.OnSetup

Nested classes/interfaces inherited from interface reactor.core.Disposable

Disposable.Composite, Disposable.Swap

Method Summary

Modifier and Type	Method and Description
HttpServerResponse	addCookie(Cookie cookie) Add an outbound cookie
HttpServerResponse	addHeader(CharSequence name, CharSequence value) Add an outbound http header, appending the value if the header already exist.
reactor.netty.http.server.HttpServerOperations	chunkedTransfer(boolean chunked) Set transfer-encoding header
HttpServerResponse	compression(boolean compress) Enable/Disable compression handling (gzip/deflate) for the underlying response
Map<CharSequence,Set<Cookie>>	cookies() Return resolved HTTP cookies
HttpServerResponse	header(CharSequence name, CharSequence value) Set an outbound header, replacing any pre-existing value.
HttpServerResponse	headers(HttpHeaders headers) Set outbound headers, replacing any pre-existing value for these headers.
InetSocketAddress	hostAddress() Return the address of the host peer.
boolean	isKeepAlive() Is the request keepAlive
boolean	isWebsocket() Return true if websocket connection (upgraded)
HttpServerResponse	keepAlive(boolean keepAlive) Set the request keepAlive if true otherwise remove the existing connection keep alive header
HttpMethod	method() Return the resolved request method (HTTP 1.1 etc)
protected HttpMessage	newFullEmptyBodyMessage()
protected void	onInboundNext(ChannelHandlerContext ctx, Object msg) React on inbound Channel.read()
protected void	onOutboundComplete() React on inbound/outbound completion (last packet)
protected void	onOutboundError(Throwable err) React on inbound/outbound error
protected HttpMessage	outboundHttpMessage() Outbound Netty HttpMessage
String	param(CharSequence key) URI parameter captured via {} "/test/{var}"
Map<String,String>	params() Return the param captured key/value map
HttpServerRequest	paramsResolver(java.util.function.Function<? super String,Map<String,String>> headerResolver)
protected void	preSendHeadersAndStatus()
Flux<?>	receiveObject() a Object inbound Flux
InetSocketAddress	remoteAddress() Return the address of the remote peer.
HttpHeaders	requestHeaders() Return inbound HttpHeaders
HttpHeaders	responseHeaders() Return headers sent back to the clients
String	scheme() Return the current scheme
Mono<Void>	send() Send headers and empty content thus delimiting a full empty body http response.
NettyOutbound	sendFile(Path file) Send content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
NettyOutbound	sendHeaders() Return a NettyOutbound successful on committed response
Mono<Void>	sendNotFound() Send 404 status HttpResponseStatus.NOT_FOUND.
Mono<Void>	sendRedirect(String location) Send redirect status HttpResponseStatus.FOUND along with a location header to the remote client.
Mono<Void>	sendWebsocket(String protocols, int maxFramePayloadLength, java.util.function.BiFunction<? super WebsocketInbound,? super WebsocketOutbound,? extends Publisher<Void>> websocketHandler) Upgrade connection to Websocket with optional subprotocol(s).
HttpServerResponse	sse() Add "text/event-stream" content-type for Server-Sent Events
HttpResponseStatus	status() Return the assigned HTTP status
HttpServerResponse	status(HttpResponseStatus status) Set an HTTP status to be sent along with the headers
String	uri() Return the resolved target address
HttpVersion	version() Return the resolved request version (HTTP 1.1 etc)
reactor.netty.http.server.HttpServerOperations	withConnection(java.util.function.Consumer<? super Connection> withConnection) Call the passed callback with a Connection to operate on the underlying Channel state.

Methods inherited from class reactor.netty.http.HttpOperations

addHandler, hasSentHeaders, markSentBody, markSentHeaderAndBody, markSentHeaders, sendFile, then, toString

Methods inherited from class reactor.netty.channel.ChannelOperations

addListener, addListeners, addReactiveBridge, alloc, as, await, awaitUninterruptibly, channel, connection, currentContext, discard, dispose, disposeSubscriber, formatName, get, inbound, isDisposed, isInboundCancelled, isInboundDisposed, isPersistent, isVoid, listener, onComplete, onDispose, onDispose, onError, onInboundCancel, onInboundClose, onInboundComplete, onInboundError, onNext, onSubscribe, onTerminate, outbound, receive, removeListener, removeListeners, sendObject, sendObject, sendUsing, setFailure, setSuccess, setSuccess, sync, syncUninterruptibly, terminate, trySuccess, unvoid

Methods inherited from class io.netty.util.concurrent.DefaultPromise

await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, checkDeadLock, executor, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, setUncancellable, toStringBuilder, tryFailure, trySuccess

Methods inherited from class io.netty.util.concurrent.AbstractFuture

get, get

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface reactor.netty.http.server.HttpServerRequest

receiveContent

Methods inherited from interface reactor.netty.NettyInbound

receive

Methods inherited from interface reactor.netty.http.server.HttpServerResponse

hasSentHeaders, options, sendWebsocket, sendWebsocket, status

Methods inherited from interface reactor.netty.NettyOutbound

alloc, neverComplete, send, sendByteArray, sendFile, sendFileChunked, sendGroups, sendObject, sendObject, sendString, sendString, sendUsing, subscribe, then, then

Methods inherited from interface reactor.netty.http.HttpInfos

path

Methods inherited from interface reactor.netty.Connection

addHandler, addHandlerFirst, addHandlerFirst, addHandlerLast, addHandlerLast, bind, from, markPersistent, onReadIdle, onWriteIdle, rebind, removeHandler, replaceHandler

Methods inherited from interface reactor.netty.DisposableChannel

address, disposeNow, disposeNow

Methods inherited from interface io.netty.util.concurrent.Promise

setUncancellable, tryFailure, trySuccess

Methods inherited from interface io.netty.util.concurrent.Future

await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess

Methods inherited from interface java.util.concurrent.Future

get, get, isCancelled, isDone

Method Detail

onInboundNext

protected void onInboundNext(ChannelHandlerContext ctx,
                             Object msg)

Description copied from class: ChannelOperations

React on inbound Channel.read()

Parameters:

ctx - the context

msg - the read payload

sendHeaders

public NettyOutbound sendHeaders()

Description copied from interface: HttpServerResponse

Return a NettyOutbound successful on committed response

Specified by:

sendHeaders in interface HttpServerResponse

Returns:

a NettyOutbound successful on committed response

withConnection

public reactor.netty.http.server.HttpServerOperations withConnection(java.util.function.Consumer<? super Connection> withConnection)

Description copied from interface: NettyInbound

Call the passed callback with a Connection to operate on the underlying Channel state. This allows for chaining inbound API.

Specified by:

withConnection in interface HttpServerRequest

Specified by:

withConnection in interface HttpServerResponse

Specified by:

withConnection in interface NettyInbound

Specified by:

withConnection in interface NettyOutbound

Overrides:

withConnection in class ChannelOperations<HttpServerRequest,HttpServerResponse>

Parameters:

withConnection - connection callback

Returns:

the Connection

newFullEmptyBodyMessage

protected HttpMessage newFullEmptyBodyMessage()

Specified by:

newFullEmptyBodyMessage in class HttpOperations<HttpServerRequest,HttpServerResponse>

addCookie

public HttpServerResponse addCookie(Cookie cookie)

Description copied from interface: HttpServerResponse

Add an outbound cookie

Specified by:

addCookie in interface HttpServerResponse

Returns:

this outbound

addHeader

public HttpServerResponse addHeader(CharSequence name,
                                    CharSequence value)

Description copied from interface: HttpServerResponse

Add an outbound http header, appending the value if the header already exist.

Specified by:

addHeader in interface HttpServerResponse

Parameters:

name - header name

value - header value

Returns:

this outbound

chunkedTransfer

public reactor.netty.http.server.HttpServerOperations chunkedTransfer(boolean chunked)

Description copied from interface: HttpServerResponse

Set transfer-encoding header

Specified by:

chunkedTransfer in interface HttpServerResponse

Parameters:

chunked - true if transfer-encoding:chunked

Returns:

this outbound

cookies

public Map<CharSequence,Set<Cookie>> cookies()

Description copied from interface: HttpInfos

Return resolved HTTP cookies

Specified by:

cookies in interface HttpInfos

Returns:

Resolved HTTP cookies

header

public HttpServerResponse header(CharSequence name,
                                 CharSequence value)

Description copied from interface: HttpServerResponse

Set an outbound header, replacing any pre-existing value.

Specified by:

header in interface HttpServerResponse

Parameters:

name - headers key

value - header value

Returns:

this outbound

headers

public HttpServerResponse headers(HttpHeaders headers)

Description copied from interface: HttpServerResponse

Set outbound headers, replacing any pre-existing value for these headers.

Specified by:

headers in interface HttpServerResponse

Parameters:

headers - netty headers map

Returns:

this outbound

isKeepAlive

public boolean isKeepAlive()

Description copied from interface: HttpInfos

Is the request keepAlive

Specified by:

isKeepAlive in interface HttpInfos

Returns:

is keep alive

isWebsocket

public boolean isWebsocket()

Description copied from interface: HttpInfos

Return true if websocket connection (upgraded)

Specified by:

isWebsocket in interface HttpInfos

Overrides:

isWebsocket in class HttpOperations<HttpServerRequest,HttpServerResponse>

Returns:

true if websocket connection

keepAlive

public HttpServerResponse keepAlive(boolean keepAlive)

Description copied from interface: HttpServerResponse

Set the request keepAlive if true otherwise remove the existing connection keep alive header

Specified by:

keepAlive in interface HttpServerResponse

Returns:

this outbound

method

public HttpMethod method()

Description copied from interface: HttpInfos

Return the resolved request method (HTTP 1.1 etc)

Specified by:

method in interface HttpInfos

Returns:

the resolved request method (HTTP 1.1 etc)

param

@Nullable
public String param(CharSequence key)

Description copied from interface: HttpServerRequest

URI parameter captured via {} "/test/{var}"

Specified by:

param in interface HttpServerRequest

Parameters:

key - param var name

Returns:

the param captured value

params

@Nullable
public Map<String,String> params()

Description copied from interface: HttpServerRequest

Return the param captured key/value map

Specified by:

params in interface HttpServerRequest

Returns:

the param captured key/value map

paramsResolver

public HttpServerRequest paramsResolver(java.util.function.Function<? super String,Map<String,String>> headerResolver)

Specified by:

paramsResolver in interface HttpServerRequest

Parameters:

headerResolver - provide a params

Returns:

this request

receiveObject

public Flux<?> receiveObject()

Description copied from interface: NettyInbound

a Object inbound Flux

Specified by:

receiveObject in interface NettyInbound

Overrides:

receiveObject in class ChannelOperations<HttpServerRequest,HttpServerResponse>

Returns:

a Object inbound Flux

hostAddress

public InetSocketAddress hostAddress()

Description copied from interface: HttpServerRequest

Return the address of the host peer.

Specified by:

hostAddress in interface HttpServerRequest

Returns:

the host's address

remoteAddress

public InetSocketAddress remoteAddress()

Description copied from interface: HttpServerRequest

Return the address of the remote peer.

Specified by:

remoteAddress in interface HttpServerRequest

Returns:

the peer's address

requestHeaders

public HttpHeaders requestHeaders()

Description copied from interface: HttpServerRequest

Return inbound HttpHeaders

Specified by:

requestHeaders in interface HttpServerRequest

Returns:

inbound HttpHeaders

scheme

public String scheme()

Description copied from interface: HttpServerRequest

Return the current scheme

Specified by:

scheme in interface HttpServerRequest

Returns:

the protocol scheme

responseHeaders

public HttpHeaders responseHeaders()

Description copied from interface: HttpServerResponse

Return headers sent back to the clients

Specified by:

responseHeaders in interface HttpServerResponse

Returns:

headers sent back to the clients

send

public Mono<Void> send()

Description copied from interface: HttpServerResponse

Send headers and empty content thus delimiting a full empty body http response.

Specified by:

send in interface HttpServerResponse

Returns:

a Mono successful on committed response

See Also:

NettyOutbound.send(Publisher)

sendFile

public NettyOutbound sendFile(Path file)

Description copied from interface: NettyOutbound

Send content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support. If the system supports it and the path resolves to a local file system File then transfer will use zero-byte copy to the peer.

It will listen for any error on write and close on terminal signal (complete|error). If more than one publisher is attached (multiple calls to send()) completion occurs after all publishers complete.

Note: this will emit FileRegion in the outbound ChannelPipeline Note: Nesting any send* method is not supported.

Specified by:

sendFile in interface NettyOutbound

Parameters:

file - the file Path

Returns:

A Publisher to signal successful sequence write (e.g. after "flush") or any error during write

sendNotFound

public Mono<Void> sendNotFound()

Description copied from interface: HttpServerResponse

Send 404 status HttpResponseStatus.NOT_FOUND.

Specified by:

sendNotFound in interface HttpServerResponse

Returns:

a Mono successful on flush confirmation

sendRedirect

public Mono<Void> sendRedirect(String location)

Description copied from interface: HttpServerResponse

Send redirect status HttpResponseStatus.FOUND along with a location header to the remote client.

Specified by:

sendRedirect in interface HttpServerResponse

Parameters:

location - the location to redirect to

Returns:

a Mono successful on flush confirmation

sse

public HttpServerResponse sse()

Description copied from interface: HttpServerResponse

Add "text/event-stream" content-type for Server-Sent Events

Specified by:

sse in interface HttpServerResponse

Returns:

the Transfer setting SSE for this http connection (e.g. event-stream)

status

public HttpResponseStatus status()

Description copied from interface: HttpServerResponse

Return the assigned HTTP status

Specified by:

status in interface HttpServerResponse

Returns:

the assigned HTTP status

status

public HttpServerResponse status(HttpResponseStatus status)

Description copied from interface: HttpServerResponse

Set an HTTP status to be sent along with the headers

Specified by:

status in interface HttpServerResponse

Parameters:

status - an HTTP status to be sent along with the headers

Returns:

this response

sendWebsocket

public Mono<Void> sendWebsocket(@Nullable
                                String protocols,
                                int maxFramePayloadLength,
                                java.util.function.BiFunction<? super WebsocketInbound,? super WebsocketOutbound,? extends Publisher<Void>> websocketHandler)

Description copied from interface: HttpServerResponse

Upgrade connection to Websocket with optional subprotocol(s). Mono and Callback are invoked on handshake success, otherwise the returned Mono fails.

Specified by:

sendWebsocket in interface HttpServerResponse

Parameters:

protocols - optional sub-protocol

maxFramePayloadLength - maximum allowable frame payload length

websocketHandler - the in/out handler for ws transport

Returns:

a Mono completing when upgrade is confirmed

uri

public String uri()

Description copied from interface: HttpInfos

Return the resolved target address

Specified by:

uri in interface HttpInfos

Returns:

the resolved target address

version

public HttpVersion version()

Description copied from interface: HttpInfos

Return the resolved request version (HTTP 1.1 etc)

Specified by:

version in interface HttpInfos

Returns:

the resolved request version (HTTP 1.1 etc)

compression

public HttpServerResponse compression(boolean compress)

Description copied from interface: HttpServerResponse

Enable/Disable compression handling (gzip/deflate) for the underlying response

Specified by:

compression in interface HttpServerResponse

Parameters:

compress - should handle compression

Returns:

this outbound

preSendHeadersAndStatus

protected void preSendHeadersAndStatus()

Specified by:

preSendHeadersAndStatus in class HttpOperations<HttpServerRequest,HttpServerResponse>

onOutboundComplete

protected void onOutboundComplete()

Description copied from class: ChannelOperations

React on inbound/outbound completion (last packet)

Overrides:

onOutboundComplete in class ChannelOperations<HttpServerRequest,HttpServerResponse>

onOutboundError

protected void onOutboundError(Throwable err)

Description copied from class: ChannelOperations

React on inbound/outbound error

Overrides:

onOutboundError in class ChannelOperations<HttpServerRequest,HttpServerResponse>

Parameters:

err - the Throwable cause

outboundHttpMessage

protected HttpMessage outboundHttpMessage()

Description copied from class: HttpOperations

Outbound Netty HttpMessage

Specified by:

outboundHttpMessage in class HttpOperations<HttpServerRequest,HttpServerResponse>

Returns:

Outbound Netty HttpMessage