diff options
Diffstat (limited to 'src/php/lib/Grpc/ClientStreamingCall.php')
| -rw-r--r-- | src/php/lib/Grpc/ClientStreamingCall.php | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/php/lib/Grpc/ClientStreamingCall.php b/src/php/lib/Grpc/ClientStreamingCall.php index 4050f7ed06..20db809ea3 100644 --- a/src/php/lib/Grpc/ClientStreamingCall.php +++ b/src/php/lib/Grpc/ClientStreamingCall.php @@ -60,10 +60,10 @@ class ClientStreamingCall extends AbstractCall * @param array $options an array of options, possible keys: * 'flags' => a number */ - public function write($data, $options = []) + public function write($data, array $options = []) { - $message_array = ['message' => $data->serialize()]; - if (isset($options['flags'])) { + $message_array = ['message' => $this->serializeMessage($data)]; + if (array_key_exists('flags', $options)) { $message_array['flags'] = $options['flags']; } $this->call->startBatch([ @@ -74,7 +74,7 @@ class ClientStreamingCall extends AbstractCall /** * Wait for the server to respond with data and a status. * - * @return [response data, status] + * @return array [response data, status] */ public function wait() { |