org.springframework.xd.rxjava

Interface Processor<I,O>

public interface Processor<I,O>

Contract for performing stream processing using RxJava within an XD processor module

Author:

Mark Pollack

Method Summary

Methods

Modifier and Type	Method and Description
rx.Observable<O>	process(rx.Observable<I> inputStream) Process a stream of messages and return an output stream.

Method Detail

process

rx.Observable<O> process(rx.Observable<I> inputStream)

Process a stream of messages and return an output stream. The input and output stream will be mapped onto receive/send operations on the message bus.

Parameters:

inputStream - Input stream the receives messages from the message bus

Returns:

Output stream of messages sent to the message bus