← All changes
|
includes/sdk/google/grpc/grpc/src/lib/ClientStreamingCall.php
+2
-2
1.2.6
→
1.4.1
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 stream of messages and then gets |
| 24 | 24 | * a single response. |
| @@ -45,9 +45,9 @@ | ||
| 45 | 45 | */ |
| 46 | 46 | public function write($data, array $options = []) |
| 47 | 47 | { |
| 48 | 48 | $message_array = ['message' => $this->_serializeMessage($data)]; |
| 49 | - if (array_key_exists('flags', $options)) { | |
| 49 | + if (\array_key_exists('flags', $options)) { | |
| 50 | 50 | $message_array['flags'] = $options['flags']; |
| 51 | 51 | } |
| 52 | 52 | $this->call->startBatch([OP_SEND_MESSAGE => $message_array]); |
| 53 | 53 | } |