Class DeliveryContext<T>

java.lang.Object
io.vertx.rxjava3.core.eventbus.DeliveryContext<T>
All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
public class DeliveryContext<T> extends Object implements io.vertx.lang.rx.RxDelegate
Encapsulates a message being delivered by Vert.x as well as providing control over the message delivery.

Used with event bus interceptors.

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

  • Field Details

    • __TYPE_ARG

      public static final io.vertx.lang.rx.TypeArg<DeliveryContext> __TYPE_ARG

    • __typeArg_0

      public final io.vertx.lang.rx.TypeArg<T> __typeArg_0

  • Constructor Details

    • DeliveryContext

      public DeliveryContext(DeliveryContext delegate)

    • DeliveryContext

      public DeliveryContext(Object delegate, io.vertx.lang.rx.TypeArg<T> typeArg_0)

  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • getDelegate

      public DeliveryContext getDelegate()
      Specified by:
      getDelegate in interface io.vertx.lang.rx.RxDelegate

    • message

      public Message<T> message()
      Returns:
      The message being delivered

    • next

      public void next()
      Call the next interceptor

    • send

      public boolean send()
      Returns:
      true if the message is being sent (point to point) or False if the message is being published

    • body

      public Object body()
      Returns:
      the value delivered by the message (before or after being processed by the codec)

    • newInstance

      public static <T> DeliveryContext<T> newInstance(DeliveryContext arg)

    • newInstance

      public static <T> DeliveryContext<T> newInstance(DeliveryContext arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)