do {
    $status = curl_multi_exec($mh, $active);
    $info = curl_multi_info_read($mh);

    if ( false !== $info ) {
        $ch = $info['handle'];
        $callout = $queue[ (string) $ch ];
        $body = curl_multi_getcontent($ch);

        // Remove the Queue
        curl_multi_remove_handle($this->cmh, $ch);

        // Handle the last mile of the request
        $result = $this->executeOnComplete($callout, $body);
        call_user_func($callout->request->callback, $result, $callout);

        // Reset active incase the callback added messages to the queue
        $active = true;
    }

} while ($status === CURLM_CALL_MULTI_PERFORM || $active);