Package io.grpc.internal

Interface MessageFramer.Sink

All Known Implementing Classes:
AbstractClientStream, AbstractServerStream
Enclosing class:
MessageFramer
public static interface MessageFramer.Sink
Sink implemented by the transport layer to receive frames and forward them to their destination.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    deliverFrame(WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages)
    Delivers a frame via the transport.

  • Method Details

    • deliverFrame

      void deliverFrame(@Nullable WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages)
      Delivers a frame via the transport.
      Parameters:
      frame - a non-empty buffer to deliver or null if the framer is being closed and there is no data to deliver.
      endOfStream - whether the frame is the last one for the GRPC stream
      flush - true if more data may not be arriving soon
      numMessages - the number of messages that this series of frames represents