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 java.lang.Object implements WriteQueue.QueuedCommand
-
-
Constructor Summary
Constructors Constructor Description AbstractQueuedCommand()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.perfmark.Link
getLink()
io.netty.channel.ChannelPromise
promise()
Returns the promise beeing notified of the success/failure of the write.void
promise(io.netty.channel.ChannelPromise promise)
Sets the promise.void
run(io.netty.channel.Channel channel)
-
-
-
Method Detail
-
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
-
-