BidiStreamingCall
final class BidiStreamingCall extends Call
Methods
Create an active bidirectional-streaming call.
Resolve and cache a unary response for every concurrent waiter.
Configure client-streaming request writes.
Write one request message.
Read the next response message or return null after a clean end.
Finish the request stream while response reads remain available.
Details
at line 21
__construct(StreamState $state, string $method, string $peer, array|callable $deserialize, Deadline $deadline, Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression = Compression::Identity)
| internal |
Create an active bidirectional-streaming 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 38
void
write(Message $message)
Write one request message.
at line 46
Message|null
read()
Read the next response message or return null after a clean end.
at line 60
void
writesDone()
Finish the request stream while response reads remain available.