Top Description Inners Fields Constructors Methods
reactor.netty5.http

public abstract Class HttpOperations<INBOUND extends reactor.netty5.NettyInbound, OUTBOUND extends reactor.netty5.NettyOutbound>

extends ChannelOperations<INBOUND extends NettyInbound, OUTBOUND extends NettyOutbound>
implements HttpInfos
Class Inheritance
All Implemented Interfaces
reactor.netty5.http.HttpInfos
Known Direct Subclasses
reactor.netty5.http.client.HttpClientOperations, reactor.netty5.http.server.HttpServerOperations
Imports
java.net.URI, java.nio.file.Path, java.util.Objects, java.util.concurrent.Callable, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLong, java.util.function.BiFunction, .Consumer, .Function, .Predicate, java.util.regex.Pattern, io.netty5.buffer.Buffer, .BufferAllocator, io.netty5.handler.codec.http.HttpObject, .EmptyLastHttpContent, .FullHttpMessage, .HttpContent, .HttpHeaderNames, .HttpMessage, .HttpUtil, .LastHttpContent, io.netty5.handler.codec.http.headers.HttpHeaders, io.netty5.handler.codec.http.websocketx.WebSocketFrame, io.netty5.util.Resource, io.netty5.channel.ChannelHandler, .CombinedChannelDuplexHandler, io.netty5.handler.codec.ByteToMessageCodec, .ByteToMessageDecoder, org.reactivestreams.Publisher, reactor.core.publisher.Mono, reactor.netty5.BufferFlux, .Connection, .ConnectionObserver, .FutureMono, .NettyInbound, .NettyOutbound, .NettyPipeline, .ReactorNetty, reactor.netty5.channel.AbortedException, .ChannelOperations, reactor.netty5.http.logging.HttpMessageArgProviderFactory, .HttpMessageLogFactory, reactor.util.Logger, .Loggers, reactor.util.annotation.Nullable
An HTTP ready ChannelOperations with state management for status and headers (first HTTP response packet).
Author
Stephane Maldini

Nested and Inner Type Summary

Modifier and TypeClass and Description
protected static class
HttpOperations.PostHeadersNettyOutbound

Field Summary

Modifier and TypeField and Description
pack-priv static final int
BODY_SENT

pack-priv static final Function<Object, Buffer>
bufferExtractorFunction

A channel object to Buffer transformer

pack-priv static final int
HEADERS_SENT

pack-priv static final ChannelHandler
HTTP_EXTRACTOR

pack-priv static final AtomicIntegerFieldUpdater<HttpOperations<INBOUND extends NettyInbound, OUTBOUND extends NettyOutbound>>
HTTP_STATE

pack-priv final HttpMessageLogFactory
httpMessageLogFactory

pack-priv static final Logger
log

Hides reactor.netty5.channel.ChannelOperations.log.

pack-priv static final int
READY

pack-priv static final Pattern
SCHEME_PATTERN

pack-priv volatile int
statusAndHeadersSent

Constructor Summary

AccessConstructor and Description
protected
HttpOperations(HttpOperations<INBOUND, OUTBOUND> replaced)

protected
HttpOperations(Connection connection, ConnectionObserver listener, HttpMessageLogFactory httpMessageLogFactory)

Method Summary

Modifier and TypeMethod and Description
public HttpOperations<INBOUND, OUTBOUND>
addHandlerFirst(String
handler name
name, ChannelHandler
handler instance
handler)

Overrides default reactor.netty5.Connection.addHandlerFirst.

Add a ChannelHandler to the beginning of the "user" io.netty5.channel.ChannelPipeline, that is just after the reactor-added codecs.
public HttpOperations<INBOUND, OUTBOUND>
addHandlerLast(String
handler name
name, ChannelHandler
handler instance
handler)

Overrides default reactor.netty5.Connection.addHandlerLast.

Add a ChannelHandler to the end of the "user" io.netty5.channel.ChannelPipeline, that is just before the reactor-added handlers like NettyPipeline#ReactiveBridge.
protected abstract void
afterMarkSentHeaders()

protected String
asDebugLogMessage(Object
the object to be transformed
o)

Overrides reactor.netty5.channel.ChannelOperations.asDebugLogMessage.

Transforms the object to a string for debug logs.
pack-priv static void
autoAddHttpExtractor(Connection c, String name, ChannelHandler handler)

protected abstract void
beforeMarkSentHeaders()

public final boolean

Returns:

true if headers have been sent
hasSentHeaders()

Has headers been sent

protected HttpMessageLogFactory
httpMessageLogFactory()

protected final String
initShortId()

Overrides reactor.netty5.channel.ChannelOperations.initShortId.

public boolean
isWebsocket()

Implements reactor.netty5.http.HttpInfos.isWebsocket.

Returns true if websocket connection (upgraded)
protected final boolean

Returns:

true if marked for the first time
markSentBody()

Mark the body sent

protected final boolean

Returns:

true if marked for the first time
markSentHeaderAndBody(Object... objectsToRelease)

Mark the headers and body sent

protected final boolean

Returns:

true if marked for the first time
markSentHeaders(Object... objectsToRelease)

Mark the headers sent

protected abstract HttpMessage
newFullBodyMessage(Buffer body)

protected abstract void
onHeadersSent()

protected abstract HttpMessage

Returns:

Outbound Netty HttpMessage
outboundHttpMessage()

Outbound Netty HttpMessage

public BufferFlux
receive()

Overrides reactor.netty5.channel.ChannelOperations.receive.

Implements reactor.netty5.NettyInbound.receive.

A Flux extension that allows for extra decoding operators
public String
requestId()

Implements reactor.netty5.http.HttpInfos.requestId.

Return a unique id for the request.
public static String

Returns:

the decoded path portion from the provided uri
resolvePath(String
an HTTP URL that may contain a path with query/fragment
uri)

Returns the decoded path portion from the provided uri

public NettyOutbound
send(Publisher<? extends Buffer>
the dataStream publishing OUT items to write on this channel
source)

Overrides default reactor.netty5.NettyOutbound.send.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
public final NettyOutbound
sendFile(Path
the file Path
file, long
where to start
position, long
how much to transfer
count)

Overrides default reactor.netty5.NettyOutbound.sendFile.

Sends content from the given Path using java.nio.channels.FileChannel#transferTo(long, long, WritableByteChannel) support, if the system supports it, the path resolves to a local file system File, compression and SSL/TLS is not enabled, then transfer will use zero-byte copy to the peer., otherwise chunked read/write will be used.
public NettyOutbound
sendObject(Object
the object to publish
message)

Overrides reactor.netty5.channel.ChannelOperations.sendObject.

Implements reactor.netty5.NettyOutbound.sendObject.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
public Mono<Void>
then()

Overrides default reactor.netty5.NettyOutbound.then.

Obtains a Mono of pending outbound(s) write completion.
public String
toString()

Overrides reactor.netty5.channel.ChannelOperations.toString.

Returns a string representation of the object.
Inherited from reactor.netty5.channel.ChannelOperations:
addMetricsHandleraddReactiveBridgeafterInboundCompleteallocasasLongTextasShortTextchannelconnectioncurrentContextdiscarddiscardWhenNoReceiverdisposedisposeSubscriberformatNamegetinboundisDisposedisInboundCancelledisInboundDisposedisPersistentisSubscriptionDisposedlisteneronCompleteonDisposeonDisposeonErroronInboundCancelonInboundCloseonInboundCompleteonInboundErroronInboundNextonNextonOutboundCompleteonOutboundErroronSubscribeonTerminateoutboundreceiveObjectsendsendObjectsendUsingterminatewithConnectionwrapInboundError

Field Detail

BODY_SENTback to summary
pack-priv static final int BODY_SENT
bufferExtractorFunctionback to summary
pack-priv static final Function<Object, Buffer> bufferExtractorFunction

A channel object to Buffer transformer

HEADERS_SENTback to summary
pack-priv static final int HEADERS_SENT
HTTP_EXTRACTORback to summary
pack-priv static final ChannelHandler HTTP_EXTRACTOR
HTTP_STATEback to summary
pack-priv static final AtomicIntegerFieldUpdater<HttpOperations<INBOUND extends NettyInbound, OUTBOUND extends NettyOutbound>> HTTP_STATE
Annotations
@SuppressWarnings:rawtypes
httpMessageLogFactoryback to summary
pack-priv final HttpMessageLogFactory httpMessageLogFactory
logback to summary
pack-priv static final Logger log

Hides reactor.netty5.channel.ChannelOperations.log.

READYback to summary
pack-priv static final int READY
SCHEME_PATTERNback to summary
pack-priv static final Pattern SCHEME_PATTERN
statusAndHeadersSentback to summary
pack-priv volatile int statusAndHeadersSent

Constructor Detail

HttpOperationsback to summary
protected HttpOperations(HttpOperations<INBOUND, OUTBOUND> replaced)
HttpOperationsback to summary
protected HttpOperations(Connection connection, ConnectionObserver listener, HttpMessageLogFactory httpMessageLogFactory)

Method Detail

addHandlerFirstback to summary
public HttpOperations<INBOUND, OUTBOUND> addHandlerFirst(String name, ChannelHandler handler)

Overrides default reactor.netty5.Connection.addHandlerFirst.

Doc from reactor.netty5.Connection.addHandlerFirst.

Add a ChannelHandler to the beginning of the "user" io.netty5.channel.ChannelPipeline, that is just after the reactor-added codecs. If a handler with a similar name already exists, this operation is skipped.

[ [reactor codecs], [<- user FIRST HANDLERS added here, user LAST HANDLERS added here ->], [reactor handlers] ]

If effectively added, the handler will be safely removed when the channel is made inactive (pool release). As the Connection object is available once the channel is in active state, events prior this state will not be available (i.e. channelRegistered, initChannel, channelActive, etc.)

Parameters
name:String

handler name

handler:ChannelHandler

handler instance

Returns:HttpOperations<INBOUND, OUTBOUND>

this Connection

Annotations
@Override
addHandlerLastback to summary
public HttpOperations<INBOUND, OUTBOUND> addHandlerLast(String name, ChannelHandler handler)

Overrides default reactor.netty5.Connection.addHandlerLast.

Doc from reactor.netty5.Connection.addHandlerLast.

Add a ChannelHandler to the end of the "user" io.netty5.channel.ChannelPipeline, that is just before the reactor-added handlers like NettyPipeline#ReactiveBridge. If a handler with a similar name already exists, this operation is skipped.

[ [reactor codecs], [<- user FIRST HANDLERS added here, user LAST HANDLERS added here ->], [reactor handlers] ]

If effectively added, the handler will be safely removed when the channel is made inactive (pool release). As the Connection object is available once the channel is in active state, events prior this state will not be available (i.e. channelRegistered, initChannel, channelActive, etc.)

Parameters
name:String

handler name

handler:ChannelHandler

handler instance

Returns:HttpOperations<INBOUND, OUTBOUND>

this Connection

Annotations
@Override
afterMarkSentHeadersback to summary
protected abstract void afterMarkSentHeaders()
asDebugLogMessageback to summary
protected String asDebugLogMessage(Object o)

Overrides reactor.netty5.channel.ChannelOperations.asDebugLogMessage.

Doc from reactor.netty5.channel.ChannelOperations.asDebugLogMessage.

Transforms the object to a string for debug logs.

Parameters
o:Object

the object to be transformed

Returns:String

the string to be logged

Annotations
@Override
autoAddHttpExtractorback to summary
pack-priv static void autoAddHttpExtractor(Connection c, String name, ChannelHandler handler)
beforeMarkSentHeadersback to summary
protected abstract void beforeMarkSentHeaders()
hasSentHeadersback to summary
public final boolean hasSentHeaders()

Has headers been sent

Returns:boolean

true if headers have been sent

httpMessageLogFactoryback to summary
protected HttpMessageLogFactory httpMessageLogFactory()
initShortIdback to summary
protected final String initShortId()

Overrides reactor.netty5.channel.ChannelOperations.initShortId.

Annotations
@Override
isWebsocketback to summary
public boolean isWebsocket()

Implements reactor.netty5.http.HttpInfos.isWebsocket.

Doc from reactor.netty5.http.HttpInfos.isWebsocket.

Returns true if websocket connection (upgraded)

Returns:boolean

true if websocket connection

Annotations
@Override
markSentBodyback to summary
protected final boolean markSentBody()

Mark the body sent

Returns:boolean

true if marked for the first time

markSentHeaderAndBodyback to summary
protected final boolean markSentHeaderAndBody(Object... objectsToRelease)

Mark the headers and body sent

Returns:boolean

true if marked for the first time

markSentHeadersback to summary
protected final boolean markSentHeaders(Object... objectsToRelease)

Mark the headers sent

Returns:boolean

true if marked for the first time

newFullBodyMessageback to summary
protected abstract HttpMessage newFullBodyMessage(Buffer body)
onHeadersSentback to summary
protected abstract void onHeadersSent()
outboundHttpMessageback to summary
protected abstract HttpMessage outboundHttpMessage()

Outbound Netty HttpMessage

Returns:HttpMessage

Outbound Netty HttpMessage

receiveback to summary
public BufferFlux receive()

Overrides reactor.netty5.channel.ChannelOperations.receive.

Implements reactor.netty5.NettyInbound.receive.

Doc from reactor.netty5.NettyInbound.receive.

A Flux extension that allows for extra decoding operators

Returns:BufferFlux

a new BufferFlux

Annotations
@Override
requestIdback to summary
public String requestId()

Implements reactor.netty5.http.HttpInfos.requestId.

Doc from reactor.netty5.http.HttpInfos.requestId.

Return a unique id for the request. The id is a combination of the id of the underlying connection and the serial number of the request received on that connection.

Format of the id: <CONNECTION_ID>-<REQUEST_NUMBER>

Example: <CONNECTION_ID>: 329c6ffd <REQUEST_NUMBER>: 5 Result: 329c6ffd-5

Returns:String

an unique id for the request

Annotations
@Override
resolvePathback to summary
public static String resolvePath(String uri)

Returns the decoded path portion from the provided uri

Parameters
uri:String

an HTTP URL that may contain a path with query/fragment

Returns:String

the decoded path portion from the provided uri

sendback to summary
public NettyOutbound send(Publisher<? extends Buffer> source)

Overrides default reactor.netty5.NettyOutbound.send.

Doc from reactor.netty5.NettyOutbound.send.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

A new NettyOutbound type (or the same) for typed send sequences.

Note

Nesting any send* method is not supported.

Note

If you need to transform from io.netty.buffer.ByteBuf to Buffer you can use io.netty5.buffer.api.adaptor.ByteBufAdaptor#extractOrCopy(BufferAllocator, io.netty.buffer.ByteBuf)

Parameters
source:Publisher<? extends Buffer>

the dataStream publishing OUT items to write on this channel

Returns:NettyOutbound

A new NettyOutbound to append further send. It will emit a complete signal successful sequence write (e.g. after "flush") or any error during write.

Annotations
@Override
@SuppressWarnings:unchecked
sendFileback to summary
public final NettyOutbound sendFile(Path file, long position, long count)

Overrides default reactor.netty5.NettyOutbound.sendFile.

Doc from reactor.netty5.NettyOutbound.sendFile.

Sends content from the given Path using java.nio.channels.FileChannel#transferTo(long, long, WritableByteChannel) support, if the system supports it, the path resolves to a local file system File, compression and SSL/TLS is not enabled, then transfer will use zero-byte copy to the peer., otherwise chunked read/write will be used.

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

Note: Nesting any send* method is not supported.

Parameters
file:Path

the file Path

position:long

where to start

count:long

how much to transfer

Returns:NettyOutbound

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

Annotations
@Override
sendObjectback to summary
public NettyOutbound sendObject(Object message)

Overrides reactor.netty5.channel.ChannelOperations.sendObject.

Implements reactor.netty5.NettyOutbound.sendObject.

Doc from reactor.netty5.NettyOutbound.sendObject.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

Note

Nesting any send* method is not supported.

Parameters
message:Object

the object to publish

Returns:NettyOutbound

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

Annotations
@Override
thenback to summary
public Mono<Void> then()

Overrides default reactor.netty5.NettyOutbound.then.

Doc from reactor.netty5.NettyOutbound.then.

Obtains a Mono of pending outbound(s) write completion.

Returns:Mono<Void>

a Mono of pending outbound(s) write completion

Annotations
@Override
toStringback to summary
public String toString()

Overrides reactor.netty5.channel.ChannelOperations.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations
@Override
reactor.netty5.http back to summary

protected final Class HttpOperations.PostHeadersNettyOutbound

extends Object
implements NettyOutbound, Consumer<Throwable>, Runnable
Class Inheritance
All Implemented Interfaces
java.lang.Runnable, java.util.function.Consumer, reactor.netty5.NettyOutbound, org.reactivestreams.Publisher

Field Summary

Modifier and TypeField and Description
pack-priv final Buffer
msg

pack-priv final HttpOperations<?, ?>
parent

pack-priv final Mono<Void>
source

Constructor Summary

AccessConstructor and Description
public
PostHeadersNettyOutbound(Mono<Void> source, HttpOperations<?, ?> parent, Buffer msg)

Method Summary

Modifier and TypeMethod and Description
public void
accept(Throwable
the input argument
throwable)

Implements java.util.function.Consumer.accept.

Performs this operation on the given argument.
public BufferAllocator
alloc()

Implements reactor.netty5.NettyOutbound.alloc.

Returns the assigned BufferAllocator.
public void
run()

Implements java.lang.Runnable.run.

Runs this operation.
public NettyOutbound
send(Publisher<? extends Buffer>
the dataStream publishing OUT items to write on this channel
publisher, Predicate<Buffer>
that returns true if explicit flush operation is needed after that buffer
predicate)

Implements reactor.netty5.NettyOutbound.send.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
public NettyOutbound
sendObject(Publisher<?>
the dataStream publishing items to write on this channel or a simple pojo supported by configured Netty handlers
dataStream, Predicate<Object>
that returns true if explicit flush operation is needed after that object
predicate)

Implements reactor.netty5.NettyOutbound.sendObject.

Sends an object through Netty pipeline.
public NettyOutbound
sendObject(Object
the object to publish
message)

Implements reactor.netty5.NettyOutbound.sendObject.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
public <S> NettyOutbound
sendUsing(Callable<? extends S>
state generator
sourceInput, BiFunction<? super Connection, ? super S, ?>
input to send
mappedInput, Consumer<? super S>
state cleaner
sourceCleanup)

Implements reactor.netty5.NettyOutbound.sendUsing.

Binds a send to a starting/cleanup lifecycle

Note

Nesting any send* method is not supported.

public Mono<Void>
then()

Overrides default reactor.netty5.NettyOutbound.then.

Obtains a Mono of pending outbound(s) write completion.
public NettyOutbound
withConnection(Consumer<? super Connection>
connection callback
withConnection)

Implements reactor.netty5.NettyOutbound.withConnection.

Call the passed callback with a Connection to operate on the underlying Channel state.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

msgback to summary
pack-priv final Buffer msg
parentback to summary
pack-priv final HttpOperations<?, ?> parent
sourceback to summary
pack-priv final Mono<Void> source

Constructor Detail

PostHeadersNettyOutboundback to summary
public PostHeadersNettyOutbound(Mono<Void> source, HttpOperations<?, ?> parent, Buffer msg)

Method Detail

acceptback to summary
public void accept(Throwable throwable)

Implements java.util.function.Consumer.accept.

Doc from java.util.function.Consumer.accept.

Performs this operation on the given argument.

Parameters
throwable:Throwable

the input argument

Annotations
@Override
allocback to summary
public BufferAllocator alloc()

Implements reactor.netty5.NettyOutbound.alloc.

Doc from reactor.netty5.NettyOutbound.alloc.

Returns the assigned BufferAllocator.

Returns:BufferAllocator

the BufferAllocator

Annotations
@Override
runback to summary
public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations
@Override
sendback to summary
public NettyOutbound send(Publisher<? extends Buffer> publisher, Predicate<Buffer> predicate)

Implements reactor.netty5.NettyOutbound.send.

Doc from reactor.netty5.NettyOutbound.send.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

A new NettyOutbound type (or the same) for typed send sequences.

Note

Nesting any send* method is not supported.

Note

If you need to transform from io.netty.buffer.ByteBuf to Buffer you can use io.netty5.buffer.api.adaptor.ByteBufAdaptor#extractOrCopy(BufferAllocator, io.netty.buffer.ByteBuf)

Parameters
publisher:Publisher<? extends Buffer>

the dataStream publishing OUT items to write on this channel

predicate:Predicate<Buffer>

that returns true if explicit flush operation is needed after that buffer

Returns:NettyOutbound

A new NettyOutbound to append further send. It will emit a complete signal successful sequence write (e.g. after "flush") or any error during write.

Annotations
@Override
sendObjectback to summary
public NettyOutbound sendObject(Publisher<?> dataStream, Predicate<Object> predicate)

Implements reactor.netty5.NettyOutbound.sendObject.

Doc from reactor.netty5.NettyOutbound.sendObject.

Sends an object through Netty pipeline. If type of Publisher, sends all signals, flushing on complete by default. Write occur in FIFO sequence.

Note

Nesting any send* method is not supported.

Parameters
dataStream:Publisher<?>

the dataStream publishing items to write on this channel or a simple pojo supported by configured Netty handlers

predicate:Predicate<Object>

that returns true if explicit flush operation is needed after that object

Returns:NettyOutbound

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

Annotations
@Override
sendObjectback to summary
public NettyOutbound sendObject(Object message)

Implements reactor.netty5.NettyOutbound.sendObject.

Doc from reactor.netty5.NettyOutbound.sendObject.

Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).

Note

Nesting any send* method is not supported.

Parameters
message:Object

the object to publish

Returns:NettyOutbound

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

Annotations
@Override
sendUsingback to summary
public <S> NettyOutbound sendUsing(Callable<? extends S> sourceInput, BiFunction<? super Connection, ? super S, ?> mappedInput, Consumer<? super S> sourceCleanup)

Implements reactor.netty5.NettyOutbound.sendUsing.

Doc from reactor.netty5.NettyOutbound.sendUsing.

Binds a send to a starting/cleanup lifecycle

Note

Nesting any send* method is not supported.

Parameters
<S>
state type
sourceInput:Callable<? extends S>

state generator

mappedInput:BiFunction<? super Connection, ? super S, ?>

input to send

sourceCleanup:Consumer<? super S>

state cleaner

Returns:NettyOutbound

a new NettyOutbound

Annotations
@Override
thenback to summary
public Mono<Void> then()

Overrides default reactor.netty5.NettyOutbound.then.

Doc from reactor.netty5.NettyOutbound.then.

Obtains a Mono of pending outbound(s) write completion.

Returns:Mono<Void>

a Mono of pending outbound(s) write completion

Annotations
@Override
withConnectionback to summary
public NettyOutbound withConnection(Consumer<? super Connection> withConnection)

Implements reactor.netty5.NettyOutbound.withConnection.

Doc from reactor.netty5.NettyOutbound.withConnection.

Call the passed callback with a Connection to operate on the underlying Channel state.

Parameters
withConnection:Consumer<? super Connection>

connection callback

Returns:NettyOutbound

the Connection

Annotations
@Override