iPublikuj / mqtt-client

	/**

	 * {@inheritdoc}

	 */

	public function subscribe(Mqtt\Subscription $subscription) : Promise\ExtendedPromiseInterface

	{

		if (!$this->isConnected) {

			return new Promise\RejectedPromise(new Exceptions\LogicException('The client is not connected.'));

		}

		return $this->startFlow(new Mqtt\Flow\OutgoingSubscribeFlow([$subscription], $this->identifierGenerator));

	}

	/**

	 * {@inheritdoc}

	/**

	 * {@inheritdoc}

	 */

	public function unsubscribe(Mqtt\Subscription $subscription) : Promise\ExtendedPromiseInterface

	{

		if (!$this->isConnected) {

			return new Promise\RejectedPromise(new Exceptions\LogicException('The client is not connected.'));

		}

		return $this->startFlow(new Mqtt\Flow\OutgoingUnsubscribeFlow([$subscription], $this->identifierGenerator));

	}

	/**

	 * {@inheritdoc}