Package io.grpc.netty
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.Link
getLink()
final io.netty.channel.ChannelPromise
promise()
Returns the promise beeing notified of the success/failure of the write.final void
promise
(io.netty.channel.ChannelPromise promise) Sets the promise.final void
run
(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.QueuedCommand
Sets the promise.- Specified by:
promise
in interfaceWriteQueue.QueuedCommand
-
promise
public final io.netty.channel.ChannelPromise promise()Description copied from interface:WriteQueue.QueuedCommand
Returns the promise beeing notified of the success/failure of the write.- Specified by:
promise
in interfaceWriteQueue.QueuedCommand
-
run
public final void run(io.netty.channel.Channel channel) - Specified by:
run
in interfaceWriteQueue.QueuedCommand
-
getLink
public io.perfmark.Link getLink()- Specified by:
getLink
in interfaceWriteQueue.QueuedCommand
-