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 Object implements com.caplin.datasource.subscription.SubjectConsumer<S>
-
-
Constructor Summary
Constructors Constructor Description ObjectPublisherConsumer(ObjectPublisher objectPublisher, SubjectInfo subjectInfo)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onError(com.caplin.datasource.SubjectError subjectError)
void
onNext(S config)
void
onStatus(com.caplin.datasource.SubjectStatus subjectStatus)
-
-
-
Constructor Detail
-
ObjectPublisherConsumer
public ObjectPublisherConsumer(ObjectPublisher objectPublisher, SubjectInfo subjectInfo)
-
-
Method Detail
-
onNext
public void onNext(S config)
- Specified by:
onNext
in interfacecom.caplin.datasource.subscription.SubjectConsumer<S>
-
onError
public void onError(com.caplin.datasource.SubjectError subjectError)
- Specified by:
onError
in interfacecom.caplin.datasource.subscription.SubjectConsumer<S>
-
onStatus
public void onStatus(com.caplin.datasource.SubjectStatus subjectStatus)
- Specified by:
onStatus
in interfacecom.caplin.datasource.subscription.SubjectConsumer<S>
-
-