public class WriteQueue extends Object
| Constructor and Description |
|---|
WriteQueue(io.netty.channel.Channel channel) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
io.netty.channel.ChannelFuture |
enqueue(QueuedCommand command) |
io.netty.channel.ChannelFuture |
enqueue(QueuedCommand command,
boolean rst) |
io.netty.channel.ChannelFuture |
failure(Throwable cause) |
void |
scheduleFlush() |
io.netty.channel.ChannelFuture |
success() |
public io.netty.channel.ChannelFuture success()
public io.netty.channel.ChannelFuture failure(Throwable cause)
public io.netty.channel.ChannelFuture enqueue(QueuedCommand command, boolean rst)
public io.netty.channel.ChannelFuture enqueue(QueuedCommand command)
public void scheduleFlush()
public void close()
Copyright © 2011–2022 The Apache Software Foundation. All rights reserved.