<?php
namespace QSnsApi;
class YarConcurrent
{
    private $uri;

    public function __construct($uri)
    {
        $this->uri = $uri;
    }

    public function call($method, $parameters, $callback)
    {
        \Yar_Concurrent_Client::call($this->uri, $method, $parameters, $callback);
        return $this;
    }

    public function loop($callback = 'QSnsApi\YarConcurrent::callback', $error_callback = 'QSnsApi\YarConcurrent::errorCallback')
    {
        \Yar_Concurrent_Client::loop($callback, $error_callback);
        return $this;
    }

    /**
     * 错误回调
     * @param $type
     * @param $error
     * @param $callinfo
     */
    static public function errorCallback($type, $error, $callinfo)
    {
        print_r($error);
    }

    /**
     * 发送所有注册的并行调用
     * @param $retval
     * @param $callinfo
     */
    static public function callback($retval, $callinfo)
    {

    }
}