Class ObjectPublisherConsumer<S>

  • All Implemented Interfaces:
    com.caplin.datasource.subscription.SubjectConsumer<S>

    public class ObjectPublisherConsumer<S>
    extends Object
    implements com.caplin.datasource.subscription.SubjectConsumer<S>
    • 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>