| Interface | Description |
|---|---|
| Processor<I,O> |
Contract for performing stream processing using Reactor within an XD processor module
|
| Class | Description |
|---|---|
| BroadcasterMessageHandler |
Adapts the item at a time delivery of a
MessageHandler
by delegating processing to a Stream
The outputStream of the processor is used to create a message and send it to the output channel. |
| MultipleBroadcasterMessageHandler |
Adapts the item at a time delivery of a
MessageHandler
by delegating processing to a Stream based on a partitionExpression. |
| ReactorReflectionUtils |
Utility class for working with the reflection API for Reactor based processors.
|