ConnectionManagerDelay.php

<?php

namespace ConnectionManager\Extra;

use React\EventLoop\Loop;
use React\EventLoop\LoopInterface;
use React\Promise\Timer;
use React\Socket\ConnectorInterface;

class ConnectionManagerDelay implements ConnectorInterface
{
    /** @var ConnectorInterface */
    private $connectionManager;

    /** @var float */
    private $delay;

    /** @var LoopInterface */
    private $loop;

    /**
     * @param ConnectorInterface $connectionManager
     * @param float $delay
     * @param ?LoopInterface $loop
     */
    public function __construct(ConnectorInterface $connectionManager, $delay, $loop = null)
    {
        if ($loop !== null && !$loop instanceof LoopInterface) { // manual type check to support legacy PHP < 7.1
            throw new \InvalidArgumentException('Argument #3 ($loop) expected null|React\EventLoop\LoopInterface');
        }

        $this->connectionManager = $connectionManager;
        $this->delay = $delay;
        $this->loop = $loop ?: Loop::get();
    }

    public function connect($uri)
    {
        $connectionManager = $this->connectionManager;

        return Timer\resolve($this->delay, $this->loop)->then(function () use ($connectionManager, $uri) {
            return $connectionManager->connect($uri);
        });
    }
}