Core/src/GrpcRequestWrapper.php
private function handleStream($response)
    {
        try {
            foreach ($response->readAll() as $count => $result) {
                $res = $this->serializer->encodeMessage($result);
                yield $res;
            }
        } catch (\Exception $ex) {
            throw $this->convertToGoogleException($ex);
        }
    }
private function handleStream($response)
    {
        try {
            foreach ($response->readAll() as $count => $result) {
                $res = $this->serializer->encodeMessage($result);
                yield $res;
            }
        } catch (\Exception $ex) {
            throw $this->convertToGoogleException($ex);
        }
    }
private function handleStream ( $ response ) { try { foreach ( $ response -> readAll ( ) as $ count => $ result ) { $ res = $ this -> serializer -> encodeMessage ( $ result ) ; yield $ res ; } } catch ( \ Exception $ ex ) { throw $ this -> convertToGoogleException ( $ ex ) ; } }
Handles a streaming response.

@param ServerStream|GaxServerStream $response
@return \Generator|array|null
Handles a streaming response .