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, Stephane Maldini

Method Summary

Methods

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

Method Detail

process

org.reactivestreams.Publisher<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 Publisher (Stream, Promise, or any valid Reactive Stream Publisher) of messages sent to the message bus