$worker->onConnect=function($conn)use($targetAddr){
    echo 'connected1';
    $conn->remote=new AsyncTcpConnection($targetAddr);
    $conn->remote->onClose=function($conn){
        echo 1;
    }；
    $conn->remote->pipe($conn);
    $conn->pipe($conn->remote);
    $conn->remote->connect();
    echo 'connected2';
};

...

$worker->onClose=function($conn){
    echo 1;
};