WyriHaximus / reactphp-child-process-messenger

        return (new Connector($loop, ['timeout' => $connectTimeout]))->connect($options['address'])->then(function (ConnectionInterface $connection) use ($options, $loop, $connectTimeout) {

            return new Promise\Promise(function ($resolve, $reject) use ($connection, $options, $loop, $connectTimeout) {

                Promise\Timer\timeout(Promise\Stream\first($connection), $connectTimeout, $loop)->then(function ($chunk) use ($resolve, $connection, $options) {

                    list($confirmation) = explode(PHP_EOL, $chunk);

                    if ($confirmation === 'syn') {

                        $connection->write('ack' . PHP_EOL);

                        $resolve(new Messenger($connection, $options));

                    }

                }, $reject);

                $connection->write(hash_hmac('sha512', $options['address'], $options['random']) . PHP_EOL);

            });

        })->then(function (Messenger $messenger) use ($loop, $termiteCallable) {

                            return Promise\Stream\first($connection);

                        }

                    })->then(function ($chunk) use ($options, $connection, $resolve) {

                        list($confirmation) = explode(PHP_EOL, $chunk);

                        if ($confirmation === 'ack') {

                            $resolve(new Messenger($connection, $options));

                        }

                    });

                }

            );

            $server->on('error', function ($et) use ($reject) {