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

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()

Methods inherited from class io.netty.buffer.DefaultByteBufHolder

content, contentToString, copy, duplicate, refCnt, release, release, retain, retain, retainedDuplicate, touch, touch

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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 interface WriteQueue.QueuedCommand

stream

StreamIdHolder stream()

endStream

boolean endStream()

replace

public io.netty.buffer.ByteBufHolder replace(io.netty.buffer.ByteBuf content)

Specified by:

replace in interface io.netty.buffer.ByteBufHolder

Overrides:

replace in class io.netty.buffer.DefaultByteBufHolder

equals

public boolean equals(java.lang.Object that)

Overrides:

equals in class io.netty.buffer.DefaultByteBufHolder

toString

public java.lang.String toString()

Overrides:

toString in class io.netty.buffer.DefaultByteBufHolder

hashCode

public int hashCode()

Overrides:

hashCode in class io.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 interface WriteQueue.QueuedCommand

promise

public void promise(io.netty.channel.ChannelPromise promise)

Description copied from interface: WriteQueue.QueuedCommand

Sets the promise.

Specified by:

promise in interface WriteQueue.QueuedCommand

run

public final void run(io.netty.channel.Channel channel)

Specified by:

run in interface WriteQueue.QueuedCommand