void
onDiscard(T subjectInfo)
onRequest(T subjectInfo, com.caplin.datasource.subscription.SubjectConsumer<S> publishObject)