Class HttpOperations.PostHeadersNettyOutbound

java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
All Implemented Interfaces:
Serializable, Publisher<Void>, NettyOutbound
Enclosing class:
HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound>

protected static final class HttpOperations.PostHeadersNettyOutbound extends AtomicBoolean implements NettyOutbound
See Also:
  • Constructor Details

  • Method Details

    • 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