IPub\MQTTClient\Flow\Envelope

Complexity

Total Complexity

12

Size/Duplication

Total Lines	138
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	getCode()	0	4	1
A	start()	0	6	1
A	accept()	0	4	1
A	next()	0	6	1
A	isFinished()	0	4	1
A	isSuccess()	0	4	1
A	getResult()	0	4	1
A	getErrorMessage()	0	4	1
A	getDeferred()	0	4	1
A	getPacket()	0	4	1
A	isSilent()	0	4	1

<?php
/**
 * Envelope.php
 *
 * @copyright      More in license.md
 * @license        http://www.ipublikuj.eu
 * @author         Adam Kadlec http://www.ipublikuj.eu
 * @package        iPublikuj:MQTTClient!
 * @subpackage     React
 * @since          1.0.0
 *
 * @date           12.03.17
 */

declare(strict_types = 1);

namespace IPub\MQTTClient\Flow;

use React\Promise;

use BinSoul\Net\Mqtt;

/**
 * Decorates flows with data required for the Client class
 *
 * @package        iPublikuj:MQTTClient!
 * @subpackage     React
 *
 * @author         Adam Kadlec <adam.kadlec@ipublikuj.eu>
 */
final class Envelope implements Mqtt\Flow
{
	/**
	 * @var Mqtt\Flow
	 */
	private $flow;

	/**
	 * @var Promise\Deferred
	 */
	private $deferred;

	/**
	 * @var Mqtt\Packet
	 */
	private $packet;

	/**
	 * @var bool
	 */
	private $isSilent;

	/**
	 * @param Mqtt\Flow $flow
	 * @param Promise\Deferred $deferred
	 * @param Mqtt\Packet|NULL $packet
	 * @param bool $isSilent
	 */
	public function __construct(
		Mqtt\Flow $flow,
		Promise\Deferred $deferred,
		?Mqtt\Packet $packet = NULL,
		bool $isSilent = FALSE
	) {
		$this->flow = $flow;
		$this->deferred = $deferred;
		$this->packet = $packet;
		$this->isSilent = $isSilent;
	}

	/**
	 * {@inheritdoc}
	 */
	public function getCode()
	{
		return $this->flow->getCode();
	}

	/**
	 * {@inheritdoc}
	 */
	public function start()
	{
		$this->packet = $this->flow->start();

		return $this->packet;
	}

	/**
	 * {@inheritdoc}
	 */
	public function accept(Mqtt\Packet $packet)
	{
		return $this->flow->accept($packet);
	}

	/**
	 * {@inheritdoc}
	 */
	public function next(Mqtt\Packet $packet)
	{
		$this->packet = $this->flow->next($packet);

		return $this->packet;
	}

	/**
	 * {@inheritdoc}
	 */
	public function isFinished()
	{
		return $this->flow->isFinished();
	}

	/**
	 * {@inheritdoc}
	 */
	public function isSuccess()
	{
		return $this->flow->isSuccess();
	}

	/**
	 * {@inheritdoc}
	 */
	public function getResult()
	{
		return $this->flow->getResult();
	}

	/**
	 * {@inheritdoc}
	 */
	public function getErrorMessage()
	{
		return $this->flow->getErrorMessage();
	}

	/**
	 * Returns the associated deferred
	 *
	 * @return Promise\Deferred
	 */
	public function getDeferred() : Promise\Deferred
	{
		return $this->deferred;
	}

	/**
	 * Returns the current packet
	 *
	 * @return Mqtt\Packet
	 */
	public function getPacket() : Mqtt\Packet
	{
		return $this->packet;
	}

	/**
	 * Indicates if the flow should emit events
	 *
	 * @return bool
	 */
	public function isSilent() : bool
	{
		return $this->isSilent;
	}
}