Interface Processor<I,​O>

Type Parameters:
I - The type observed
O - The type produced
All Superinterfaces:
Publisher<O>, Subscriber<I>
All Known Subinterfaces:
Processor.Iso<V>, Processor.Transactional<I,​O>, Processor.TransactionalIso<V>

public interface Processor<I,​O>
extends Publisher<O>, Subscriber<I>
A combination of an Publisher and Subscriber.

Processors are expected to broadcast their submitted values to any registered observers, though filtering or other transformations may be applied.

Submitting a completion event to the processor will result in a completion event being passed to every subscriber, and the rejection of further events being submitted.