Package io.servicetalk.concurrent.api
Interface ProcessorSignalsConsumer<T>
-
- Type Parameters:
T- Type of itemsconsumedby this consumer.
public interface ProcessorSignalsConsumer<T>Consumer of items from aPublisherProcessorSignalsHolderorBlockingProcessorSignalsHolder.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidconsumeItem(T item)Consumes the passeditem.voidconsumeTerminal()Consumes the termination of the holder.voidconsumeTerminal(java.lang.Throwable cause)Consumes theThrowablethat terminated the holder.
-
-
-
Method Detail
-
consumeItem
void consumeItem(@Nullable T item)Consumes the passeditem.- Parameters:
item- to consume. This will benullif anullwas added to the holder.
-
consumeTerminal
void consumeTerminal(java.lang.Throwable cause)
Consumes theThrowablethat terminated the holder.- Parameters:
cause- of termination of the holder.
-
consumeTerminal
void consumeTerminal()
Consumes the termination of the holder.
-
-