Package org.springframework.xd.rxjava

Interface Summary

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

Class Summary

Class	Description
MultipleSubjectMessageHandler	Adapts the item at a time delivery of a MessageHandler by delegating processing to an Observable based on a partitionExpression.
SubjectMessageHandler	Adapts the item at a time delivery of a MessageHandler by delegating processing to a Observable.