protected static interface AbstractServerStream.Sink
Modifier and Type | Method and Description |
---|---|
void |
cancel(Status status)
Tears down the stream, typically in the event of a timeout.
|
void |
request(int numMessages)
Requests up to the given number of messages from the call to be delivered.
|
void |
writeFrame(WritableBuffer frame,
boolean flush,
int numMessages)
Sends an outbound frame to the remote end point.
|
void |
writeHeaders(Metadata headers)
Sends response headers to the remote end point.
|
void |
writeTrailers(Metadata trailers,
boolean headersSent,
Status status)
Sends trailers to the remote end point.
|
void writeHeaders(Metadata headers)
headers
- the headers to be sent to client.void writeFrame(@Nullable WritableBuffer frame, boolean flush, int numMessages)
frame
- a buffer containing the chunk of data to be sent.flush
- true
if more data may not be arriving soonnumMessages
- the number of messages this frame representsvoid writeTrailers(Metadata trailers, boolean headersSent, Status status)
trailers
- metadata to be sent to the end pointheadersSent
- true
if response headers have already been sent.status
- the status that the call ended withvoid request(int numMessages)
AbstractStream.TransportState.requestMessagesFromDeframer(int)
on the transport thread.void cancel(Status status)
This is a clone of ServerStream.cancel(Status)
.
Copyright © 2018. All rights reserved.