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 aPublisherProcessorSignalsHolder
orBlockingProcessorSignalsHolder
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
consumeItem(T item)
Consumes the passeditem
.void
consumeTerminal()
Consumes the termination of the holder.void
consumeTerminal(java.lang.Throwable cause)
Consumes theThrowable
that terminated the holder.
-
-
-
Method Detail
-
consumeItem
void consumeItem(@Nullable T item)
Consumes the passeditem
.- Parameters:
item
- to consume. This will benull
if anull
was added to the holder.
-
consumeTerminal
void consumeTerminal(java.lang.Throwable cause)
Consumes theThrowable
that terminated the holder.- Parameters:
cause
- of termination of the holder.
-
consumeTerminal
void consumeTerminal()
Consumes the termination of the holder.
-
-