public class NettyLumberjackPeerContext extends Object implements Runnable
It is used to slow down the peer socket reading should we have too much data in the send queue.
It is also used for keep alive sending/receiving.
| Modifier and Type | Method and Description |
|---|---|
protected void |
receivedKeepAliveAck() |
protected void |
refreshKeepAlive() |
void |
run() |
protected void |
setFuture(io.netty.util.concurrent.ScheduledFuture<?> future) |
Copyright © 2023. All rights reserved.