public interface KVSSubscription<K,V> extends SubscriptionCollection<MapEvent<K,V>>, BaseSubscriber, EventConsumer<K,V>
Modifier and Type | Method and Description |
---|---|
boolean |
hasSubscribers() |
default boolean |
hasValueSubscribers() |
default boolean |
keyedView() |
boolean |
needsPrevious() |
void |
notifyEvent(MapEvent<K,V> changeEvent) |
void |
registerDownstream(@NotNull EventConsumer<K,V> subscription) |
void |
registerKeySubscriber(@NotNull RequestContext rc,
@NotNull Subscriber<? super K> subscriber,
@NotNull Filter<? super K> filter)
Add a Subscription for the keys changed on this Map
|
void |
registerTopicSubscriber(@NotNull RequestContext rc,
@NotNull TopicSubscriber<? super K,? super V> subscriber) |
void |
setKvStore(KeyValueStore<K,V> store) |
void |
unregisterTopicSubscriber(@NotNull TopicSubscriber subscriber) |
entrySubscriberCount, keySubscriberCount, registerSubscriber, subscriberCount, topicSubscriberCount, unregisterSubscriber
close, closeQuietly, closeQuietly
index, index, isIndexAware, isTcpBufferFullEnough, onEndOfSubscription
void registerKeySubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull Subscriber<? super K> subscriber, @NotNull @NotNull Filter<? super K> filter)
rc
- RequestContext to usesubscriber
- to addfilter
- a list of filter operationsvoid registerTopicSubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull TopicSubscriber<? super K,? super V> subscriber)
void unregisterTopicSubscriber(@NotNull @NotNull TopicSubscriber subscriber)
void registerDownstream(@NotNull @NotNull EventConsumer<K,V> subscription)
default boolean keyedView()
boolean needsPrevious()
void setKvStore(KeyValueStore<K,V> store)
void notifyEvent(MapEvent<K,V> changeEvent)
notifyEvent
in interface EventConsumer<K,V>
boolean hasSubscribers()
default boolean hasValueSubscribers()
Copyright © 2021. All rights reserved.