software.chronicle.datagrid.internal.map

Interface ObjectSubscription<K,V>

All Superinterfaces:

AutoCloseable, BaseSubscriber, Closeable, EventConsumer<K,V>, KVSSubscription<K,V>, net.openhft.chronicle.core.io.QueryCloseable, SubscriptionCollection<MapEvent<K,V>>

All Known Implementing Classes:

MapKVSSubscription, QueueObjectSubscription, RemoteKVSSubscription

public interface ObjectSubscription<K,V>
extends KVSSubscription<K,V>

Method Summary

Methods inherited from interface software.chronicle.datagrid.internal.map.KVSSubscription

hasSubscribers, hasValueSubscribers, keyedView, needsPrevious, notifyEvent, registerDownstream, registerKeySubscriber, registerKeySubscriber, registerTopicSubscriber, setKvStore, unregisterTopicSubscriber

Methods inherited from interface software.chronicle.datagrid.pubsub.SubscriptionCollection

entrySubscriberCount, keySubscriberCount, registerSubscriber, subscriberCount, topicSubscriberCount, unregisterSubscriber

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosed, isClosing, throwExceptionIfClosed

Methods inherited from interface software.chronicle.datagrid.pubsub.BaseSubscriber

index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription