Package io.grpc.netty

Class NettyClientStream.Sink

java.lang.Object
io.grpc.netty.NettyClientStream.Sink
All Implemented Interfaces:
AbstractClientStream.Sink
Enclosing class:
NettyClientStream

private class NettyClientStream.Sink extends Object implements AbstractClientStream.Sink
  • Constructor Details

    • Sink

      private Sink()
  • Method Details

    • writeHeaders

      public void writeHeaders(Metadata headers, byte[] requestPayload)
      Description copied from interface: AbstractClientStream.Sink
      Sends the request headers to the remote end point.
      Specified by:
      writeHeaders in interface AbstractClientStream.Sink
      Parameters:
      headers - the metadata to be sent
      requestPayload - the payload needs to be sent in the headers if not null. Should only be used when sending an unary GET request
    • writeHeadersInternal

      private void writeHeadersInternal(Metadata headers, byte[] requestPayload)
    • writeFrameInternal

      private void writeFrameInternal(WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages)
    • writeFrame

      public void writeFrame(WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages)
      Description copied from interface: AbstractClientStream.Sink
      Sends an outbound frame to the remote end point.
      Specified by:
      writeFrame in interface AbstractClientStream.Sink
      Parameters:
      frame - a buffer containing the chunk of data to be sent, or null if endOfStream with no data to send
      endOfStream - true if this is the last frame; flush is guaranteed to be true if this is true
      flush - true if more data may not be arriving soon
      numMessages - the number of messages this series of frames represents, must be >= 0.
    • cancel

      public void cancel(Status status)
      Description copied from interface: AbstractClientStream.Sink
      Tears down the stream, typically in the event of a timeout. This method may be called multiple times and from any thread.

      This is a clone of ClientStream.cancel(Status); AbstractClientStream.cancel(io.grpc.Status) delegates to this method.

      Specified by:
      cancel in interface AbstractClientStream.Sink