$remote_connection->pipe($connection); 
$connection->pipe($remote_connection);
$remote_connection->connect();

<?php
$context = array(
 'ssl' => array(
 'local_cert' => app_paths['ssl_public_key'], // Alternatively, it can be a crt file
 'local_pk' => app_paths['ssl_private_key'],
 'verify_peer' => false,
 'allow_self_signed' => true,
 )
);
$worker = new Worker('tcp://0.0.0.0:' . $args['port'], $context);
$worker->transport = 'ssl';
$worker->onMessage = function ($connection, $buffer) use ($args) {
 list($method, $addr, $http_version) = explode('', $buffer);
 $remote_connection = new AsyncTcpConnection("tcp://{$args['proxy-ip']}:{$args['port']}");
 if ($method !== 'CONNECT') {
 $remote_connection->send($buffer);
 } else {
 $connection->send("HTTP/1.1 200 Connection Established\r\n\r\n");
 }
 $remote_connection->pipe($connection);
 $connection->pipe($remote_connection);
 $remote_connection->connect();
};