reactor.netty.http

Class HttpOperations.PostHeadersNettyOutbound

java.lang.Object

java.util.concurrent.atomic.AtomicBoolean

reactor.netty.http.HttpOperations.PostHeadersNettyOutbound

All Implemented Interfaces:

Serializable, Runnable, Consumer<Throwable>, Publisher<Void>, NettyOutbound

Enclosing class:

HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound>

protected static final class HttpOperations.PostHeadersNettyOutbound
extends AtomicBoolean
implements NettyOutbound, Consumer<Throwable>, Runnable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PostHeadersNettyOutbound(Mono<Void> source, HttpOperations<?,?> parent, ByteBuf msg)

Method Summary

Modifier and Type	Method and Description
void	accept(Throwable throwable)
ByteBufAllocator	alloc() Returns the assigned ByteBufAllocator.
void	run()
NettyOutbound	send(Publisher<? extends ByteBuf> dataStream, Predicate<ByteBuf> predicate) Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
NettyOutbound	sendObject(Object message) Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
NettyOutbound	sendObject(Publisher<?> dataStream, Predicate<Object> predicate) Sends an object through Netty pipeline.
<S> NettyOutbound	sendUsing(Callable<? extends S> sourceInput, BiFunction<? super Connection,? super S,?> mappedInput, Consumer<? super S> sourceCleanup) Binds a send to a starting/cleanup lifecycle
Mono<Void>	then() Obtains a Mono of pending outbound(s) write completion.
NettyOutbound	withConnection(Consumer<? super Connection> withConnection) Call the passed callback with a Connection to operate on the underlying Channel state.

Methods inherited from class java.util.concurrent.atomic.AtomicBoolean

compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.netty.NettyOutbound

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

PostHeadersNettyOutbound

public PostHeadersNettyOutbound(Mono<Void> source,
                                HttpOperations<?,?> parent,
                                @Nullable
                                ByteBuf msg)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

accept

public void accept(Throwable throwable)

Specified by:

accept in interface Consumer<Throwable>

then

public Mono<Void> then()

Description copied from interface: NettyOutbound

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

Specified by:

then in interface NettyOutbound

Returns:

a Mono of pending outbound(s) write completion

alloc

public ByteBufAllocator alloc()

Description copied from interface: NettyOutbound

Returns the assigned ByteBufAllocator.

Specified by:

alloc in interface NettyOutbound

Returns:

the ByteBufAllocator

send

public NettyOutbound send(Publisher<? extends ByteBuf> dataStream,
                          Predicate<ByteBuf> predicate)

Description copied from interface: NettyOutbound

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.

Specified by:

send in interface NettyOutbound

Parameters:

dataStream - the dataStream publishing OUT items to write on this channel

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

Returns:

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.

sendObject

public NettyOutbound sendObject(Publisher<?> dataStream,
                                Predicate<Object> predicate)

Description copied from interface: NettyOutbound

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.

Specified by:

sendObject in interface NettyOutbound

Parameters:

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

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

Returns:

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

sendObject

public NettyOutbound sendObject(Object message)

Description copied from interface: NettyOutbound

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.

Specified by:

sendObject in interface NettyOutbound

Parameters:

message - the object to publish

Returns:

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

sendUsing

public <S> NettyOutbound sendUsing(Callable<? extends S> sourceInput,
                                   BiFunction<? super Connection,? super S,?> mappedInput,
                                   Consumer<? super S> sourceCleanup)

Description copied from interface: NettyOutbound

Binds a send to a starting/cleanup lifecycle

Note: Nesting any send* method is not supported.

Specified by:

sendUsing in interface NettyOutbound

Type Parameters:

S - state type

Parameters:

sourceInput - state generator

mappedInput - input to send

sourceCleanup - state cleaner

Returns:

a new NettyOutbound

withConnection

public NettyOutbound withConnection(Consumer<? super Connection> withConnection)

Description copied from interface: NettyOutbound

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

Specified by:

withConnection in interface NettyOutbound

Parameters:

withConnection - connection callback

Returns:

the Connection