Copied!

ClientStream is the response object from a gRPC client streaming API call.

CloneableInstantiable
Methods
public __construct(Grpc\ClientStreamingCall $clientStreamingCall, array $streamingDescriptor = [], ?Psr\Log\LoggerInterface $logger = NULL)
 

ClientStream constructor.

  • param \ClientStreamingCall $clientStreamingCall The gRPC client streaming call object
  • param array $streamingDescriptor
  • param null|\LoggerInterface $logger A PSR-3 compliant logger.
public getClientStreamingCall()
 

Return the underlying gRPC call object

  • return \Grpc\ClientStreamingCall|mixed
public readResponse()
 

Read the response from the server, completing the streaming call.

  • throws \ApiException
  • return mixed The response object from the server
public write( $request)
 

Write request to the server.

  • param mixed $request The request to write
public writeAllAndReadResponse(array $requests)
 

Write all data in $dataArray and read the response from the server, completing the streaming call.

  • param array $requests An iterator of request objects to write to the server
  • return mixed The response object from the server
Properties
private $call = NULL
private ?Psr\Log\LoggerInterface $logger
Methods
private getJwtToken(array $headers) : ?array
 
  • param array $headers
  • return null|array<string,string|false>
private logRequest(Google\Auth\Logging\RpcLogEvent $event) : void
 
  • param \RpcLogEvent $event
private logResponse(Google\Auth\Logging\RpcLogEvent $event) : void
 
  • param \RpcLogEvent $event
private truncatePayload(?string $payload) : ?string
 
  • param null|string $payload
  • return string
© 2025 Bruce Wells