diff --git a/src/ReactMqttClient.php b/src/ReactMqttClient.php index be9a68b..1d78f38 100644 --- a/src/ReactMqttClient.php +++ b/src/ReactMqttClient.php @@ -274,13 +274,13 @@ function () { /** * Subscribes to a topic filter. */ - public function subscribe(Subscription $subscription): ExtendedPromiseInterface + public function subscribe(Subscription $subscription, Subscription ...$subscriptions): ExtendedPromiseInterface { if (!$this->isConnected) { return new RejectedPromise(new LogicException('The client is not connected.')); } - return $this->startFlow($this->flowFactory->buildOutgoingSubscribeFlow([$subscription])); + return $this->startFlow($this->flowFactory->buildOutgoingSubscribeFlow(func_get_args())); } /**