1. class
  2. Hypervel
  3. \
  4. Grpc
  5. \
  6. Client
  7. \
  8. Call

Call

abstract class 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, GrpcOperationHandle|null $operationHandle = null)

Create an active call around its initial transport attempt.

Metadata
metadata()

Return the server's initial metadata.

Metadata
trailers()

Return the server's trailing metadata.

Status
status()

Return the final gRPC status without throwing for an RPC error.

string
peer()

Return the normalized peer authority selected for this call.

void
cancel()

Cancel this logical call.

Message
waitForUnaryResponse()

Resolve and cache a unary response for every concurrent waiter.

Message|null
readResponse()

Read and deserialize the next response message.

void
beginReading()

Claim this call's single streaming response reader.

void
endReading()

Release this call's streaming response reader.

void
configureWriter(Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression)

Configure client-streaming request writes.

void
writeRequest(Message $message)

Write one client-streaming request message.

void
finishWrites()

Half-close the client-streaming request body.

__destruct()

Finish a dropped call and release its unfinished native resources.

Details

at line 87
protected __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)

Create an active call around its initial transport attempt.

Parameters

StreamState $state
string $method
string $peer
array|callable $deserialize
Deadline $deadline
RetryPolicy|null $retryPolicy
Closure|null $attemptFactory
RetryBackoff|null $retryBackoff
GrpcOperationHandle|null $operationHandle

at line 123
Metadata metadata()

Return the server's initial metadata.

Return Value

Metadata

at line 169
Metadata trailers()

Return the server's trailing metadata.

Return Value

Metadata

at line 200
Status status()

Return the final gRPC status without throwing for an RPC error.

Return Value

Status

at line 230
string peer()

Return the normalized peer authority selected for this call.

Return Value

string

at line 238
void cancel()

Cancel this logical call.

Return Value

void

at line 283
protected Message waitForUnaryResponse()

Resolve and cache a unary response for every concurrent waiter.

Return Value

Message

at line 336
protected Message|null readResponse()

Read and deserialize the next response message.

Return Value

Message|null

at line 346
protected void beginReading()

Claim this call's single streaming response reader.

Return Value

void

at line 358
protected void endReading()

Release this call's streaming response reader.

Return Value

void

at line 366
protected void configureWriter(Connection $connection, FrameEncoder $requestEncoder, Compression $requestCompression)

Configure client-streaming request writes.

Parameters

Connection $connection
FrameEncoder $requestEncoder
Compression $requestCompression

Return Value

void

at line 388
protected void writeRequest(Message $message)

Write one client-streaming request message.

Parameters

Message $message

Return Value

void

at line 452
protected void finishWrites()

Half-close the client-streaming request body.

Return Value

void

at line 967
__destruct()

Finish a dropped call and release its unfinished native resources.