org.springframework.cloud.stream.annotation.rxjava

Interface RxJavaProcessor<I,O>

Deprecated.

in favor of StreamListener with reactive types

@Deprecated
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) Deprecated.

Method Detail

process

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

Deprecated.