Package io.grpc.netty
Class SendGrpcFrameCommand
- java.lang.Object
-
- io.netty.buffer.DefaultByteBufHolder
-
- io.grpc.netty.SendGrpcFrameCommand
-
- All Implemented Interfaces:
WriteQueue.QueuedCommand
,io.netty.buffer.ByteBufHolder
,io.netty.util.ReferenceCounted
final class SendGrpcFrameCommand extends io.netty.buffer.DefaultByteBufHolder implements WriteQueue.QueuedCommand
Command sent from the transport to the Netty channel to send a GRPC frame to the remote endpoint.
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
endStream
private io.perfmark.Link
link
private io.netty.channel.ChannelPromise
promise
private StreamIdHolder
stream
-
Constructor Summary
Constructors Constructor Description SendGrpcFrameCommand(StreamIdHolder stream, io.netty.buffer.ByteBuf content, boolean endStream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) boolean
endStream()
boolean
equals(java.lang.Object that)
io.perfmark.Link
getLink()
int
hashCode()
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.io.netty.buffer.ByteBufHolder
replace(io.netty.buffer.ByteBuf content)
void
run(io.netty.channel.Channel channel)
(package private) StreamIdHolder
stream()
java.lang.String
toString()
-
-
-
Field Detail
-
stream
private final StreamIdHolder stream
-
endStream
private final boolean endStream
-
link
private final io.perfmark.Link link
-
promise
private io.netty.channel.ChannelPromise promise
-
-
Constructor Detail
-
SendGrpcFrameCommand
SendGrpcFrameCommand(StreamIdHolder stream, io.netty.buffer.ByteBuf content, boolean endStream)
-
-
Method Detail
-
getLink
public io.perfmark.Link getLink()
- Specified by:
getLink
in interfaceWriteQueue.QueuedCommand
-
stream
StreamIdHolder stream()
-
endStream
boolean endStream()
-
replace
public io.netty.buffer.ByteBufHolder replace(io.netty.buffer.ByteBuf content)
- Specified by:
replace
in interfaceio.netty.buffer.ByteBufHolder
- Overrides:
replace
in classio.netty.buffer.DefaultByteBufHolder
-
equals
public boolean equals(java.lang.Object that)
- Overrides:
equals
in classio.netty.buffer.DefaultByteBufHolder
-
toString
public java.lang.String toString()
- Overrides:
toString
in classio.netty.buffer.DefaultByteBufHolder
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classio.netty.buffer.DefaultByteBufHolder
-
promise
public 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
-
promise
public void promise(io.netty.channel.ChannelPromise promise)
Description copied from interface:WriteQueue.QueuedCommand
Sets the promise.- Specified by:
promise
in interfaceWriteQueue.QueuedCommand
-
run
public final void run(io.netty.channel.Channel channel)
- Specified by:
run
in interfaceWriteQueue.QueuedCommand
-
-