UnaryCall
final class UnaryCall extends Call
Methods
__construct(StreamState $state, string $method, string $peer, array|callable $deserialize, Deadline $deadline, RetryPolicy|null $retryPolicy = null, Closure|null $attemptFactory = null, RetryBackoff|null $retryBackoff = null)
Create an active unary call.
Message
waitForUnaryResponse()
Resolve and cache a unary response for every concurrent waiter.
from
Call
void
configureWriter(Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression)
Configure client-streaming request writes.
from
Call
Message
wait()
Wait for and return the unary response message.
Details
at line 21
__construct(StreamState $state, string $method, string $peer, array|callable $deserialize, Deadline $deadline, RetryPolicy|null $retryPolicy = null, Closure|null $attemptFactory = null, RetryBackoff|null $retryBackoff = null)
| internal |
Create an active unary call.
in
Call at line 211
string
peer()
Return the normalized peer authority selected for this call.
in
Call at line 219
protected Message
waitForUnaryResponse()
Resolve and cache a unary response for every concurrent waiter.
in
Call at line 264
protected Message|null
readResponse()
Read and deserialize the next response message.
in
Call at line 274
protected void
beginReading()
Claim this call's single streaming response reader.
in
Call at line 286
protected void
endReading()
Release this call's streaming response reader.
in
Call at line 294
protected void
configureWriter(Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression)
Configure client-streaming request writes.
in
Call at line 316
protected void
writeRequest(Message $message)
Write one client-streaming request message.
in
Call at line 376
protected void
finishWrites()
Half-close the client-streaming request body.
at line 46
Message
wait()
Wait for and return the unary response message.