Lines Matching refs:Grpc

47     if ($status->code !== Grpc\STATUS_OK) {
62         $stub->EmptyCall(new Grpc\Testing\EmptyMessage())->wait();
90     $request = new Grpc\Testing\SimpleRequest();
91     $request->setResponseType(Grpc\Testing\PayloadType::COMPRESSABLE);
93     $payload = new Grpc\Testing\Payload();
94     $payload->setType(Grpc\Testing\PayloadType::COMPRESSABLE);
109     hardAssert($payload->getType() === Grpc\Testing\PayloadType::COMPRESSABLE,
241             $request = new Grpc\Testing\StreamingInputCallRequest();
242             $payload = new Grpc\Testing\Payload();
268     $request = new Grpc\Testing\StreamingOutputCallRequest();
269     $request->setResponseType(Grpc\Testing\PayloadType::COMPRESSABLE);
271         $response_parameters = new Grpc\Testing\ResponseParameters();
282             $payload->getType() === Grpc\Testing\PayloadType::COMPRESSABLE,
303         $request = new Grpc\Testing\StreamingOutputCallRequest();
304         $request->setResponseType(Grpc\Testing\PayloadType::COMPRESSABLE);
305         $response_parameters = new Grpc\Testing\ResponseParameters();
308         $payload = new Grpc\Testing\Payload();
318             $payload->getType() === Grpc\Testing\PayloadType::COMPRESSABLE,
351     hardAssert($status->code === Grpc\STATUS_CANCELLED,
363     $request = new Grpc\Testing\StreamingOutputCallRequest();
364     $request->setResponseType(Grpc\Testing\PayloadType::COMPRESSABLE);
365     $response_parameters = new Grpc\Testing\ResponseParameters();
368     $payload = new Grpc\Testing\Payload();
376     hardAssert($call->getStatus()->code === Grpc\STATUS_CANCELLED,
383     $request = new Grpc\Testing\StreamingOutputCallRequest();
384     $request->setResponseType(Grpc\Testing\PayloadType::COMPRESSABLE);
385     $response_parameters = new Grpc\Testing\ResponseParameters();
388     $payload = new Grpc\Testing\Payload();
395     hardAssert($call->getStatus()->code === Grpc\STATUS_DEADLINE_EXCEEDED,
408     $request = new Grpc\Testing\SimpleRequest();
409     $request->setResponseType(Grpc\Testing\PayloadType::COMPRESSABLE);
411     $payload = new Grpc\Testing\Payload();
412     $payload->setType(Grpc\Testing\PayloadType::COMPRESSABLE);
441     $streaming_request = new Grpc\Testing\StreamingOutputCallRequest();
443     $response_parameters = new Grpc\Testing\ResponseParameters();
469     $echo_status = new Grpc\Testing\EchoStatus();
473     $request = new Grpc\Testing\SimpleRequest();
488     $streaming_request = new Grpc\Testing\StreamingOutputCallRequest();
506     $call = $stub->UnimplementedCall(new Grpc\Testing\EmptyMessage());
508     hardAssert($status->code === Grpc\STATUS_UNIMPLEMENTED,
515     $call = $stub->UnimplementedCall(new Grpc\Testing\EmptyMessage());
517     hardAssert($status->code === Grpc\STATUS_UNIMPLEMENTED,
562             $ssl_credentials = Grpc\ChannelCredentials::createSsl(
565             $ssl_credentials = Grpc\ChannelCredentials::createSsl();
570         $opts['credentials'] = Grpc\ChannelCredentials::createInsecure();
606         $stub = new Grpc\Testing\UnimplementedServiceClient($server_address,
609         $stub = new Grpc\Testing\TestServiceClient($server_address, $opts);