while ($req->connected) {