public interface ObjectSubscription<K,V> extends KVSSubscription<K,V>
hasSubscribers, hasValueSubscribers, keyedView, needsPrevious, notifyEvent, registerDownstream, registerKeySubscriber, registerKeySubscriber, registerTopicSubscriber, setKvStore, unregisterTopicSubscriber
entrySubscriberCount, keySubscriberCount, registerSubscriber, subscriberCount, topicSubscriberCount, unregisterSubscriber
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
isClosed, isClosing, throwExceptionIfClosed
index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription
Copyright © 2021. All rights reserved.