D E H O P R S

D

destroy() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

E

EnableRxJavaProcessor - Annotation Type in org.springframework.cloud.stream.annotation.rxjava

Annotation that identifies the class as RxJava processor module.

H

handleMessageInternal(Message<?>) - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

O

org.springframework.cloud.stream.annotation.rxjava - package org.springframework.cloud.stream.annotation.rxjava

P

process(Observable<I>) - Method in interface org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessor

R

RxJavaProcessor<I,O> - Interface in org.springframework.cloud.stream.annotation.rxjava

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

RxJavaProcessorConfiguration - Class in org.springframework.cloud.stream.annotation.rxjava

Configuration class for RxJava module support.

RxJavaProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration

S

subjectMessageHandler() - Method in class org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration

SubjectMessageHandler - Class in org.springframework.cloud.stream.annotation.rxjava

Adapts the item at a time delivery of a MessageHandler by delegating processing to a Observable.

SubjectMessageHandler(RxJavaProcessor) - Constructor for class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

D E H O P R S