Package io.servicetalk.concurrent.api
Interface ProcessorSignalsConsumer<T>
- Type Parameters:
T
- Type of itemsconsumed
by this consumer.
public interface ProcessorSignalsConsumer<T>
Consumer of items from a
PublisherProcessorSignalsHolder
or BlockingProcessorSignalsHolder
.-
Method Summary
Modifier and TypeMethodDescriptionvoid
consumeItem
(T item) Consumes the passeditem
.void
Consumes the termination of the holder.void
consumeTerminal
(Throwable cause) Consumes theThrowable
that terminated the holder.
-
Method Details
-
consumeItem
Consumes the passeditem
.- Parameters:
item
- to consume. This will benull
if anull
was added to the holder.
-
consumeTerminal
Consumes theThrowable
that terminated the holder.- Parameters:
cause
- of termination of the holder.
-
consumeTerminal
void consumeTerminal()Consumes the termination of the holder.
-