iPublikuj / mqtt-client

		$deferred = new Promise\Deferred;

		$internalFlow = new Flow\Envelope($flow, $deferred, $packet, $isSilent);

		if ($packet !== NULL) {

			if ($this->writtenFlow !== NULL) {

				$this->sendingFlows[] = $internalFlow;

			} else {

				$this->stream->write($packet);

				$this->writtenFlow = $internalFlow;

				$this->handleSend();

			}

		} else {

			$this->loop->futureTick(function () use ($internalFlow) {

				$this->finishFlow($internalFlow);

			});

		}

		return $deferred->promise();

	}

			return;

		}

		if ($response !== NULL) {

			if ($this->writtenFlow !== NULL) {

				$this->sendingFlows[] = $flow;

			} else {

				$this->stream->write($response);

				$this->writtenFlow = $flow;

				$this->handleSend();

			}

		} elseif ($flow->isFinished()) {

			$this->loop->futureTick(function () use ($flow) {

				$this->finishFlow($flow);

			});

		}

	}

	/**