Package io.servicetalk.concurrent.api

Interface ProcessorSignalsConsumer<T>

Type Parameters:
T - Type of items consumed by this consumer.
public interface ProcessorSignalsConsumer<T>
Consumer of items from a PublisherProcessorSignalsHolder or BlockingProcessorSignalsHolder.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    consumeItem(T item)
    Consumes the passed item.
    void
    consumeTerminal()
    Consumes the termination of the holder.
    void
    consumeTerminal(Throwable cause)
    Consumes the Throwable that terminated the holder.

  • Method Details

    • consumeItem

      void consumeItem(@Nullable T item)
      Consumes the passed item.
      Parameters:
      item - to consume. This will be null if a null was added to the holder.

    • consumeTerminal

      void consumeTerminal(Throwable cause)
      Consumes the Throwable that terminated the holder.
      Parameters:
      cause - of termination of the holder.

    • consumeTerminal

      void consumeTerminal()
      Consumes the termination of the holder.