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 22
__construct(StreamState $state, string $method, string $peer, array|callable $deserialize, Deadline $deadline, Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression = Compression::Identity, GrpcOperationHandle|null $operationHandle = null)
| internal |
Create an active bidirectional-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 47
void
write(Message $message)
Write one request message.
at line 55
Message|null
read()
Read the next response message or return null after a clean end.
at line 69
void
writesDone()
Finish the request stream while response reads remain available.