org.springframework.xd.rxjava (spring-xd-rxjava 1.2.0.RC1 API)

Interface Summary
Interface Description

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

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`.

Package org.springframework.xd.rxjava