org.springframework.xd.reactor

Interface Processor<I,O>

public interface Processor<I,O>

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

Author:

Mark Pollack

Method Summary

Methods

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

Method Detail

process

reactor.rx.Stream<O> process(reactor.rx.Stream<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