public class DatagridWireOutPublisher
extends net.openhft.chronicle.network.connection.VanillaWireOutPublisher
Constructor and Description |
---|
DatagridWireOutPublisher(@NotNull net.openhft.chronicle.wire.WireType wireType) |
Modifier and Type | Method and Description |
---|---|
void |
addWireConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer) |
void |
applyAction(@NotNull net.openhft.chronicle.wire.WireOut outWire) |
boolean |
removeBytesConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer) |
applyAction, canTakeMoreData, clear, isEmpty, performClose, put, threadSafetyCheck, toString, wireType
assertCloseablesClosed, clearUsedByThread, close, createdHere, disableCloseableTracing, enableCloseableTracing, isClosed, isClosing, isInUserThread, performCloseInBackground, referenceId, resetUsedByThread, shouldPerformCloseInBackground, shouldWaitForClosed, throwExceptionIfClosed, throwExceptionIfClosedInSetter, unmonitor, waitForCloseablesToClose, waitForClosed, warnAndCloseIfNotClosed
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, isClosed, newThrottledWireOutPublisher, publish
closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed
public DatagridWireOutPublisher(@NotNull @NotNull net.openhft.chronicle.wire.WireType wireType)
public void applyAction(@NotNull @NotNull net.openhft.chronicle.wire.WireOut outWire)
applyAction
in interface net.openhft.chronicle.network.connection.WireOutPublisher
applyAction
in class net.openhft.chronicle.network.connection.VanillaWireOutPublisher
public void addWireConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer)
public boolean removeBytesConsumer(net.openhft.chronicle.network.connection.WireOutConsumer wireOutConsumer)
Copyright © 2021. All rights reserved.