ServerStreamingCall
final class ServerStreamingCall extends Call
Methods
Create an active server-streaming call.
Resolve and cache a unary response for every concurrent waiter.
Configure client-streaming request writes.
Read the next response message or return null after a clean end.
Yield every response message until the server completes the stream.
Details
at line 22
__construct(StreamState $state, string $method, string $peer, array|callable $deserialize, Deadline $deadline, RetryPolicy|null $retryPolicy = null, Closure|null $attemptFactory = null, RetryBackoff|null $retryBackoff = null, GrpcOperationHandle|null $operationHandle = null)
| internal |
Create an active server-streaming call.
in
Call at line 228
string
peer()
Return the normalized peer authority selected for this call.
in
Call at line 236
void
cancel()
Cancel this logical call.
in
Call at line 281
protected Message
waitForUnaryResponse()
Resolve and cache a unary response for every concurrent waiter.
in
Call at line 332
protected Message|null
readResponse()
Read and deserialize the next response message.
in
Call at line 342
protected void
beginReading()
Claim this call's single streaming response reader.
in
Call at line 354
protected void
endReading()
Release this call's streaming response reader.
in
Call at line 362
protected void
configureWriter(Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression)
Configure client-streaming request writes.
in
Call at line 384
protected void
writeRequest(Message $message)
Write one client-streaming request message.
in
Call at line 448
protected void
finishWrites()
Half-close the client-streaming request body.
in
Call at line 959
__destruct()
Release unfinished native call resources.
at line 49
Message|null
read()
Read the next response message or return null after a clean end.
at line 65
iterable
responses()
Yield every response message until the server completes the stream.