org.springframework.cloud.stream.annotation.rxjava

Interface RxJavaProcessor<I,O>

public interface RxJavaProcessor<I,O>

Marker interface that RxJava processor module uses to provide the implementation bean.

Author:

Mark Pollack, Ilayaperumal Gopinathan

Method Summary

Modifier and Type	Method and Description
rx.Observable<O>	process(rx.Observable<I> input)

Method Detail

process

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