T
- Type of items consumed
by this consumer.public interface ProcessorSignalsConsumer<T>
PublisherProcessorSignalsHolder
or BlockingProcessorSignalsHolder
.Modifier and Type | Method and Description |
---|---|
void |
consumeItem(T item)
Consumes the passed
item . |
void |
consumeTerminal()
Consumes the termination of the holder.
|
void |
consumeTerminal(java.lang.Throwable cause)
Consumes the
Throwable that terminated the holder. |
void consumeItem(@Nullable T item)
item
.item
- to consume. This will be null
if a null
was added to the holder.void consumeTerminal(java.lang.Throwable cause)
Throwable
that terminated the holder.cause
- of termination of the holder.void consumeTerminal()