← All changes
|
includes/sdk/google/grpc/grpc/src/lib/ServerStreamingCall.php
+3
-3
1.1.1
→
1.4.2
View file →
| @@ -16,9 +16,9 @@ | ||
| 16 | 16 | * See the License for the specific language governing permissions and |
| 17 | 17 | * limitations under the License. |
| 18 | 18 | * |
| 19 | 19 | */ |
| 20 | -namespace Dudlewebs\WPMCS\Grpc; | |
| 20 | +namespace Dudlewebs\WPMCS\GCP\Grpc; | |
| 21 | 21 | |
| 22 | 22 | /** |
| 23 | 23 | * Represents an active call that sends a single message and then gets a |
| 24 | 24 | * stream of responses. |
| @@ -36,9 +36,9 @@ | ||
| 36 | 36 | */ |
| 37 | 37 | public function start($data, array $metadata = [], array $options = []) |
| 38 | 38 | { |
| 39 | 39 | $message_array = ['message' => $this->_serializeMessage($data)]; |
| 40 | - if (array_key_exists('flags', $options)) { | |
| 40 | + if (\array_key_exists('flags', $options)) { | |
| 41 | 41 | $message_array['flags'] = $options['flags']; |
| 42 | 42 | } |
| 43 | 43 | $this->call->startBatch([OP_SEND_INITIAL_METADATA => $metadata, OP_SEND_MESSAGE => $message_array, OP_SEND_CLOSE_FROM_CLIENT => \true]); |
| 44 | 44 | } |
| @@ -56,9 +56,9 @@ | ||
| 56 | 56 | $this->metadata = $read_event->metadata; |
| 57 | 57 | } |
| 58 | 58 | $response = $read_event->message; |
| 59 | 59 | while ($response !== null) { |
| 60 | - yield $this->_deserializeResponse($response); | |
| 60 | + (yield $this->_deserializeResponse($response)); | |
| 61 | 61 | $response = $this->call->startBatch([OP_RECV_MESSAGE => \true])->message; |
| 62 | 62 | } |
| 63 | 63 | } |
| 64 | 64 | /** |