Package io.grpc.netty

Class NettyServerStream.Sink

java.lang.Object
io.grpc.netty.NettyServerStream.Sink
All Implemented Interfaces:
AbstractServerStream.Sink
Enclosing class:
NettyServerStream

private class NettyServerStream.Sink extends Object implements AbstractServerStream.Sink
  • Constructor Details

    • Sink

      private Sink()
  • Method Details

    • writeHeaders

      public void writeHeaders(Metadata headers, boolean flush)
      Description copied from interface: AbstractServerStream.Sink
      Sends response headers to the remote end point.
      Specified by:
      writeHeaders in interface AbstractServerStream.Sink
      Parameters:
      headers - the headers to be sent to client.
    • writeFrame

      public void writeFrame(WritableBuffer frame, boolean flush, int numMessages)
      Description copied from interface: AbstractServerStream.Sink
      Sends an outbound frame to the remote end point.
      Specified by:
      writeFrame in interface AbstractServerStream.Sink
      Parameters:
      frame - a buffer containing the chunk of data to be sent.
      flush - true if more data may not be arriving soon
      numMessages - the number of messages this frame represents
    • writeTrailers

      public void writeTrailers(Metadata trailers, boolean headersSent, Status status)
      Description copied from interface: AbstractServerStream.Sink
      Sends trailers to the remote end point. This call implies end of stream.
      Specified by:
      writeTrailers in interface AbstractServerStream.Sink
      Parameters:
      trailers - metadata to be sent to the end point
      headersSent - true if response headers have already been sent.
      status - the status that the call ended with
    • cancel

      public void cancel(Status status)
      Description copied from interface: AbstractServerStream.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 ServerStream.cancel(Status).

      Specified by:
      cancel in interface AbstractServerStream.Sink