public final class MapSimpleSubscription<E> extends net.openhft.chronicle.core.io.SimpleCloseable implements SimpleSubscription<E>
Constructor and Description |
---|
MapSimpleSubscription(Reference<E> reference,
Function<Object,E> valueReader) |
Modifier and Type | Method and Description |
---|---|
int |
entrySubscriberCount() |
int |
keySubscriberCount() |
void |
notifyMessage(Object e) |
protected void |
performClose() |
void |
registerSubscriber(@NotNull RequestContext rc,
@NotNull Subscriber<? super E> subscriber,
@NotNull Filter<? super E> filter) |
int |
subscriberCount() |
int |
topicSubscriberCount() |
void |
unregisterSubscriber(@NotNull Subscriber subscriber) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
public void registerSubscriber(@NotNull @NotNull RequestContext rc, @NotNull @NotNull Subscriber<? super E> subscriber, @NotNull @NotNull Filter<? super E> filter)
registerSubscriber
in interface SubscriptionCollection<E>
public void unregisterSubscriber(@NotNull @NotNull Subscriber subscriber)
unregisterSubscriber
in interface SubscriptionCollection<E>
public int keySubscriberCount()
keySubscriberCount
in interface SubscriptionCollection<E>
public int entrySubscriberCount()
entrySubscriberCount
in interface SubscriptionCollection<E>
public int topicSubscriberCount()
topicSubscriberCount
in interface SubscriptionCollection<E>
public int subscriberCount()
subscriberCount
in interface SubscriptionCollection<E>
public void notifyMessage(Object e)
notifyMessage
in interface SimpleSubscription<E>
protected void performClose()
performClose
in class net.openhft.chronicle.core.io.SimpleCloseable
Copyright © 2021. All rights reserved.