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 java.lang.Object implements AbstractClientStream.Sink
-
-
Constructor Summary
Constructors Modifier Constructor Description private
Sink()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel(Status status)
Tears down the stream, typically in the event of a timeout.void
writeFrame(WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages)
Sends an outbound frame to the remote end point.private void
writeFrameInternal(WritableBuffer frame, boolean endOfStream, boolean flush, int numMessages)
void
writeHeaders(Metadata headers, byte[] requestPayload)
Sends the request headers to the remote end point.private void
writeHeadersInternal(Metadata headers, byte[] requestPayload)
-
-
-
Method Detail
-
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 interfaceAbstractClientStream.Sink
- Parameters:
headers
- the metadata to be sentrequestPayload
- 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 interfaceAbstractClientStream.Sink
- Parameters:
frame
- a buffer containing the chunk of data to be sent, ornull
ifendOfStream
with no data to sendendOfStream
-true
if this is the last frame;flush
is guaranteed to betrue
if this istrue
flush
-true
if more data may not be arriving soonnumMessages
- 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 interfaceAbstractClientStream.Sink
-
-