Class WriteQueue.AbstractQueuedCommand
java.lang.Object
io.grpc.netty.WriteQueue.AbstractQueuedCommand
- All Implemented Interfaces:
WriteQueue.QueuedCommand
- Direct Known Subclasses:
CancelClientStreamCommand, CancelServerStreamCommand, CreateStreamCommand, ForcefulCloseCommand, GracefulCloseCommand, GracefulServerCloseCommand, SendPingCommand, SendResponseHeadersCommand
- Enclosing class:
WriteQueue
abstract static class WriteQueue.AbstractQueuedCommand
extends Object
implements WriteQueue.QueuedCommand
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionio.perfmark.LinkgetLink()final io.netty.channel.ChannelPromisepromise()Returns the promise beeing notified of the success/failure of the write.final voidpromise(io.netty.channel.ChannelPromise promise) Sets the promise.final voidrun(io.netty.channel.Channel channel)
-
Field Details
-
promise
private io.netty.channel.ChannelPromise promise -
link
private final io.perfmark.Link link
-
-
Constructor Details
-
AbstractQueuedCommand
AbstractQueuedCommand()
-
-
Method Details
-
promise
public final void promise(io.netty.channel.ChannelPromise promise) Description copied from interface:WriteQueue.QueuedCommandSets the promise.- Specified by:
promisein interfaceWriteQueue.QueuedCommand
-
promise
public final io.netty.channel.ChannelPromise promise()Description copied from interface:WriteQueue.QueuedCommandReturns the promise beeing notified of the success/failure of the write.- Specified by:
promisein interfaceWriteQueue.QueuedCommand
-
run
public final void run(io.netty.channel.Channel channel) - Specified by:
runin interfaceWriteQueue.QueuedCommand
-
getLink
public io.perfmark.Link getLink()- Specified by:
getLinkin interfaceWriteQueue.QueuedCommand
-