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 final boolean
    endStream
     
    private final io.perfmark.Link
    link
     
    private io.netty.channel.ChannelPromise
    promise
     
    private final 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(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)
     
    final void
    run(io.netty.channel.Channel channel)
     
    (package private) StreamIdHolder
    stream()
     
    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 Object

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

  • Field Details

    • stream

      private final StreamIdHolder stream

    • endStream

      private final boolean endStream

    • promise

      private io.netty.channel.ChannelPromise promise

  • Constructor Details

    • SendGrpcFrameCommand

      SendGrpcFrameCommand(StreamIdHolder stream, io.netty.buffer.ByteBuf content, boolean endStream)

  • Method Details

    • 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(Object that)
      Overrides:
      equals in class io.netty.buffer.DefaultByteBufHolder

    • toString

      public 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