Dazzle\Zmq\ZmqBuffer

Complexity

Total Complexity

10

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	send()	0	17	3
A	end()	0	9	2
B	handleWriteEvent()	0	22	4

<?php

namespace Dazzle\Zmq;

use Dazzle\Event\BaseEventEmitter;
use Dazzle\Loop\LoopInterface;
use ZMQ;
use ZMQSocket as RawZMQSocket;
use ZMQSocketException;

class ZmqBuffer extends BaseEventEmitter
{
    /**
     * @var RawZMQSocket
     */
    public $socket;

    /**
     * @var bool
     */
    public $closed = false;

    /**
     * @var bool
     */
    public $listening = false;

    /**
     * @var LoopInterface
     */
    private $loop;

    /**
     * @var resource
     */
    private $fd;

    /**
     * @var callable
     */
    private $writeListener;

    /**
     * @var string[]
     */
    private $messages = [];

    /**
     * @param RawZMQSocket $socket
     * @param resource $fd
     * @param LoopInterface $loop
     * @param $writeListener
     */
    public function __construct(RawZMQSocket $socket, $fd, LoopInterface $loop, $writeListener)
    {
        $this->socket = $socket;
        $this->fd = $fd;
        $this->loop = $loop;
        $this->writeListener = $writeListener;
    }

    /**
     * Send message.
     *
     * @param string $message
     * @return bool
     */
    public function send($message)
    {
        if ($this->closed)
        {
            return false;
        }

        $this->messages[] = $message;

        if (!$this->listening)
        {
            $this->listening = true;
            $this->loop->addWriteStream($this->fd, $this->writeListener);
        }

        return true;
    }

    /**
     * Close buffer.
     */
    public function end()
    {
        $this->closed = true;

        if (!$this->listening)
        {
            $this->emit('end');
        }
    }

    /**
     * Handle ZMQ Write Event.
     */
    public function handleWriteEvent()
    {
        foreach ($this->messages as $i=>$message)
        {
            try
            {
                $message = (array) $message;
                $sent = (bool) $this->socket->sendmulti($message, ZMQ::MODE_DONTWAIT);

$sent is not used, you could remove the assignment.

                unset($this->messages[$i]);
                if (0 === count($this->messages))
                {
                    $this->loop->removeWriteStream($this->fd);
                    $this->listening = false;
                    $this->emit('end');
                }
            }
            catch (ZMQSocketException $ex)

The class ZMQSocketException does not exist. Is this class maybe located in a folder that is not analyzed, or in a newer version of your dependencies than listed in your composer.lock/composer.json?

            {
                $this->emit('error', [ $ex ]);
            }
        }
    }
}