Top Description Fields Constructors Methods
reactor.netty.http.server

pack-priv final Class Http2StreamBridgeServerHandler

extends ChannelDuplexHandler
implements ChannelFutureListener
Class Inheritance
All Implemented Interfaces
io.netty.channel.ChannelFutureListener, io.netty.util.concurrent.GenericFutureListener, java.util.EventListener
Imports
java.net.SocketAddress, java.time.Duration, .ZonedDateTime, java.util.Optional, java.util.function.BiFunction, .BiPredicate, io.netty.buffer.ByteBuf, io.netty.channel.ChannelDuplexHandler, .ChannelFuture, .ChannelFutureListener, .ChannelHandlerContext, .ChannelPromise, io.netty.handler.codec.DecoderResult, io.netty.handler.codec.http.DefaultHttpContent, .HttpObject, .HttpRequest, .HttpResponse, .HttpResponseStatus, .LastHttpContent, io.netty.handler.codec.http.cookie.ServerCookieDecoder, .ServerCookieEncoder, io.netty.handler.codec.http2.Http2StreamFrameToHttpObjectCodec, io.netty.handler.ssl.SslHandler, io.netty.util.ReferenceCountUtil, reactor.core.publisher.Mono, reactor.netty.Connection, .ConnectionObserver, .ReactorNetty, reactor.netty.http.logging.HttpMessageArgProviderFactory, .HttpMessageLogFactory, reactor.util.annotation.Nullable
This handler is intended to work together with Http2StreamFrameToHttpObjectCodec it converts the outgoing messages into objects expected by Http2StreamFrameToHttpObjectCodec.
Author
Violeta Georgieva

Field Summary

Modifier and TypeField and Description
pack-priv final BiPredicate<HttpServerRequest, HttpServerResponse>
compress

pack-priv final ServerCookieDecoder
cookieDecoder

pack-priv final ServerCookieEncoder
cookieEncoder

pack-priv final HttpServerFormDecoderProvider
formDecoderProvider

pack-priv final BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>
forwardedHeaderHandler

pack-priv final HttpMessageLogFactory
httpMessageLogFactory

pack-priv final ConnectionObserver
listener

pack-priv final BiFunction<? super Mono<Void>, ? super Connection, ? extends Mono<Void>>
mapHandle

pack-priv boolean
pendingResponse

Flag to indicate if a request is not yet fully responded.

pack-priv final Duration
readTimeout

pack-priv SocketAddress
remoteAddress

pack-priv final Duration
requestTimeout

pack-priv Boolean
secured

Constructor Summary

AccessConstructor and Description
pack-priv
Http2StreamBridgeServerHandler(BiPredicate<HttpServerRequest, HttpServerResponse> compress, ServerCookieDecoder decoder, ServerCookieEncoder encoder, HttpServerFormDecoderProvider formDecoderProvider, BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo> forwardedHeaderHandler, HttpMessageLogFactory httpMessageLogFactory, ConnectionObserver listener, BiFunction<? super Mono<Void>, ? super Connection, ? extends Mono<Void>> mapHandle, Duration readTimeout, Duration requestTimeout)

Method Summary

Modifier and TypeMethod and Description
public void
channelRead(ChannelHandlerContext ctx, Object msg)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.
public void
handlerAdded(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelHandlerAdapter.handlerAdded.

Implements io.netty.channel.ChannelHandler.handlerAdded.

Gets called after the ChannelHandler was added to the actual context and it's ready to handle events.
public void
operationComplete(ChannelFuture
the source Future which called this callback
future)

Implements io.netty.util.concurrent.GenericFutureListener.operationComplete.

Invoked when the operation associated with the Future has been completed.
public void
write(ChannelHandlerContext
the ChannelHandlerContext for which the write operation is made
ctx, Object
the message to write
msg, ChannelPromise
the ChannelPromise to notify once the operation completes
promise)

Overrides io.netty.channel.ChannelDuplexHandler.write.

Implements io.netty.channel.ChannelOutboundHandler.write.

Calls ChannelHandlerContext#write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline.
Inherited from io.netty.channel.ChannelDuplexHandler:
bindcloseconnectderegisterdisconnectflushread

Field Detail

compressback to summary
pack-priv final BiPredicate<HttpServerRequest, HttpServerResponse> compress
cookieDecoderback to summary
pack-priv final ServerCookieDecoder cookieDecoder
cookieEncoderback to summary
pack-priv final ServerCookieEncoder cookieEncoder
formDecoderProviderback to summary
pack-priv final HttpServerFormDecoderProvider formDecoderProvider
forwardedHeaderHandlerback to summary
pack-priv final BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo> forwardedHeaderHandler
httpMessageLogFactoryback to summary
pack-priv final HttpMessageLogFactory httpMessageLogFactory
listenerback to summary
pack-priv final ConnectionObserver listener
mapHandleback to summary
pack-priv final BiFunction<? super Mono<Void>, ? super Connection, ? extends Mono<Void>> mapHandle
pendingResponseback to summary
pack-priv boolean pendingResponse

Flag to indicate if a request is not yet fully responded.

readTimeoutback to summary
pack-priv final Duration readTimeout
remoteAddressback to summary
pack-priv SocketAddress remoteAddress
requestTimeoutback to summary
pack-priv final Duration requestTimeout
securedback to summary
pack-priv Boolean secured

Constructor Detail

Http2StreamBridgeServerHandlerback to summary
pack-priv Http2StreamBridgeServerHandler(BiPredicate<HttpServerRequest, HttpServerResponse> compress, ServerCookieDecoder decoder, ServerCookieEncoder encoder, HttpServerFormDecoderProvider formDecoderProvider, BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo> forwardedHeaderHandler, HttpMessageLogFactory httpMessageLogFactory, ConnectionObserver listener, BiFunction<? super Mono<Void>, ? super Connection, ? extends Mono<Void>> mapHandle, Duration readTimeout, Duration requestTimeout)

Method Detail

channelReadback to summary
public void channelRead(ChannelHandlerContext ctx, Object msg)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Annotations
@Override
handlerAddedback to summary
public void handlerAdded(ChannelHandlerContext ctx)

Overrides io.netty.channel.ChannelHandlerAdapter.handlerAdded.

Implements io.netty.channel.ChannelHandler.handlerAdded.

Doc from io.netty.channel.ChannelHandler.handlerAdded.

Gets called after the ChannelHandler was added to the actual context and it's ready to handle events.

Annotations
@Override
operationCompleteback to summary
public void operationComplete(ChannelFuture future)

Implements io.netty.util.concurrent.GenericFutureListener.operationComplete.

Doc from io.netty.util.concurrent.GenericFutureListener.operationComplete.

Invoked when the operation associated with the Future has been completed.

Parameters
future:ChannelFuture

the source Future which called this callback

Annotations
@Override
writeback to summary
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)

Overrides io.netty.channel.ChannelDuplexHandler.write.

Implements io.netty.channel.ChannelOutboundHandler.write.

Doc from io.netty.channel.ChannelDuplexHandler.write.

Calls ChannelHandlerContext#write(Object, ChannelPromise) to forward to the next ChannelOutboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Parameters
ctx:ChannelHandlerContext

Doc from io.netty.channel.ChannelOutboundHandler.write.

the ChannelHandlerContext for which the write operation is made

msg:Object

Doc from io.netty.channel.ChannelOutboundHandler.write.

the message to write

promise:ChannelPromise

Doc from io.netty.channel.ChannelOutboundHandler.write.

the ChannelPromise to notify once the operation completes

Annotations
@Override
@SuppressWarnings:FutureReturnValueIgnored