ocpu\Request\Broker\CURLBulk

Complexity

Total Complexity

8

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	5	1
A	exec()	0	12	3
A	close()	0	7	2
A	addRequest()	0	6	1
A	getHandle()	0	4	1

<?php

namespace ocpu\Request\Broker;

use ocpu\Request\IRequestBroker;
use ocpu\Request\IRequestBrokerMulti;

class CURLBulk implements IRequestBrokerMulti
{
    private $request;
    private $requests;

    public function init()
    {
        $this->request = \curl_multi_init();
        $this->requests = [];
    }

    public function exec()
    {
        $index = null;
        do {
            curl_multi_exec($this->request, $index);
        } while ($index > 0);
        $responses = [];
        foreach ($this->requests as $i => $request) {
            $responses[$i] = \curl_multi_getcontent($request);
        }
        return $responses;
    }

    public function close(): void
    {
        foreach ($this->requests as $request) {
            \curl_multi_remove_handle($this->request, $request);
        }
        curl_multi_close($this->request);
    }

    public function addRequest(IRequestBroker $request)
    {
        $req = $request->getHandle();
        $this->requests[] = $req;
        \curl_multi_add_handle($this->request, $req);
    }

    public function getHandle()
    {
        return $this->request;
    }
}