Package org.springframework.xd.reactor

Interface Summary

Interface	Description
Processor<I,O>	Contract for performing stream processing using Reactor within an XD processor module

Class Summary

Class	Description
AbstractReactorMessageHandler	Abstract base class for Reactor based MessageHandlers.
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.