public final class RemoteIndexQueueView<K extends net.openhft.chronicle.wire.Marshallable,V extends net.openhft.chronicle.wire.Marshallable> extends net.openhft.chronicle.network.connection.AbstractStatelessClient<MapWireHandler.EventId> implements IndexQueueView<Subscriber<IndexedValue<V>>,V>
Constructor and Description |
---|
RemoteIndexQueueView(@NotNull RequestContext context,
@NotNull Asset asset) |
Modifier and Type | Method and Description |
---|---|
Asset |
asset() |
void |
registerSubscriber(@NotNull Subscriber<IndexedValue<V>> subscriber,
@NotNull IndexQuery<V> vanillaIndexQuery) |
@Nullable Object |
underlying() |
void |
unregisterSubscriber(@NotNull Subscriber<IndexedValue<V>> listener) |
attempt, performClose, proxyReturnBoolean, proxyReturnBooleanWithArgs, proxyReturnBooleanWithSequence, proxyReturnByte, proxyReturnByte, proxyReturnInt, proxyReturnInt, proxyReturnLong, proxyReturnLongWithArgs, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnUint16, proxyReturnVoid, proxyReturnVoid, proxyReturnWireConsumer, proxyReturnWireConsumerInOut, proxyReturnWireTypedObject, readBoolean, readInt, sendBytes, sendEvent, sendEventAsync, toParameters, toParameters, writeMetaDataForKnownTID
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isClosed
close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
public RemoteIndexQueueView(@NotNull @NotNull RequestContext context, @NotNull @NotNull Asset asset)
public Asset asset()
@Nullable public @Nullable Object underlying()
underlying
in interface Assetted<Object>
public void registerSubscriber(@NotNull @NotNull Subscriber<IndexedValue<V>> subscriber, @NotNull @NotNull IndexQuery<V> vanillaIndexQuery)
registerSubscriber
in interface IndexQueueView<Subscriber<IndexedValue<V extends net.openhft.chronicle.wire.Marshallable>>,V extends net.openhft.chronicle.wire.Marshallable>
public void unregisterSubscriber(@NotNull @NotNull Subscriber<IndexedValue<V>> listener)
unregisterSubscriber
in interface IndexQueueView<Subscriber<IndexedValue<V extends net.openhft.chronicle.wire.Marshallable>>,V extends net.openhft.chronicle.wire.Marshallable>
Copyright © 2021. All rights reserved.