Package com.caplin.motif.datasource

Class ObjectPublisherConsumer<S>

java.lang.Object

com.caplin.motif.datasource.ObjectPublisherConsumer<S>

All Implemented Interfaces:

com.caplin.datasource.subscription.SubjectConsumer<S>

public class ObjectPublisherConsumer<S>
extends java.lang.Object
implements com.caplin.datasource.subscription.SubjectConsumer<S>

Constructor Summary

Constructors

Constructor	Description
ObjectPublisherConsumer(ObjectPublisher objectPublisher, SubjectInfo subjectInfo)

Method Summary

Modifier and Type	Method	Description
void	onError(com.caplin.datasource.SubjectError subjectError)
void	onNext(S config)
void	onStatus(com.caplin.datasource.SubjectStatus subjectStatus)

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectPublisherConsumer

public ObjectPublisherConsumer(ObjectPublisher objectPublisher,
                               SubjectInfo subjectInfo)

Method Detail

onNext

public void onNext(S config)

Specified by:

onNext in interface com.caplin.datasource.subscription.SubjectConsumer<S>

onError

public void onError(com.caplin.datasource.SubjectError subjectError)

Specified by:

onError in interface com.caplin.datasource.subscription.SubjectConsumer<S>

onStatus

public void onStatus(com.caplin.datasource.SubjectStatus subjectStatus)

Specified by:

onStatus in interface com.caplin.datasource.subscription.SubjectConsumer<S>