Package io.grpc.internal

Interface MessageFramer.Sink

All Known Implementing Classes:

AbstractClientStream, AbstractServerStream, NettyClientStream, NettyServerStream, ServletServerStream, ServletServerStream

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