org.springframework.xd.reactor

Class AbstractReactorMessageHandler.ChannelForwardingSubscriber

java.lang.Object

reactor.rx.action.support.DefaultSubscriber<java.lang.Object>

org.springframework.xd.reactor.AbstractReactorMessageHandler.ChannelForwardingSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<java.lang.Object>, reactor.core.support.NonBlocking

Enclosing class:

AbstractReactorMessageHandler

protected class AbstractReactorMessageHandler.ChannelForwardingSubscriber
extends reactor.rx.action.support.DefaultSubscriber<java.lang.Object>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractReactorMessageHandler.ChannelForwardingSubscriber()

Method Summary

Methods

Modifier and Type	Method and Description
void	onComplete()
void	onError(java.lang.Throwable throwable)
void	onNext(java.lang.Object outputObject)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class reactor.rx.action.support.DefaultSubscriber

getCapacity, isReactivePull

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractReactorMessageHandler.ChannelForwardingSubscriber

protected AbstractReactorMessageHandler.ChannelForwardingSubscriber()

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<java.lang.Object>

Overrides:

onSubscribe in class reactor.rx.action.support.DefaultSubscriber<java.lang.Object>

onNext

public void onNext(java.lang.Object outputObject)

Specified by:

onNext in interface org.reactivestreams.Subscriber<java.lang.Object>

Overrides:

onNext in class reactor.rx.action.support.DefaultSubscriber<java.lang.Object>

onError

public void onError(java.lang.Throwable throwable)

Specified by:

onError in interface org.reactivestreams.Subscriber<java.lang.Object>

Overrides:

onError in class reactor.rx.action.support.DefaultSubscriber<java.lang.Object>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<java.lang.Object>

Overrides:

onComplete in class reactor.rx.action.support.DefaultSubscriber<java.lang.Object>