PeeHaa\AsyncTwitter\Api\StatusStream

Complexity

Total Complexity

13

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	resolveReadPromise()	0	13	2
A	update()	0	6	2
A	end()	0	6	1
A	fail()	0	11	2
B	read()	0	20	5
A	close()	0	4	1

<?php declare(strict_types = 1);

namespace PeeHaa\AsyncTwitter\Api;

use Amp\Deferred;
use Amp\Failure;
use Amp\Promise;
use Amp\Success;

class StatusStream implements Stream
{
    private $buffer = [];

    /**
     * @var Deferred
     */
    private $readPromisor = null;

    private $error = null;
    private $ended = false;

    private function resolveReadPromise($value): bool
    {
        $promisor = $this->readPromisor;

Equals sign not aligned with surrounding assignments; expected 11 spaces but found 1 space

        $this->readPromisor = null;

        if ($promisor === null) {
            return false;
        }

        $promisor->succeed($value);

The method succeed() does not seem to exist on object<Amp\Deferred>.

        return true;
    }

    public function update($status)
    {
        if (!$this->resolveReadPromise($status)) {
            $this->buffer[] = $status;
        }
    }

    public function end()
    {
        $this->ended = true;

        $this->resolveReadPromise(null);
    }

    public function fail(\Throwable $error)
    {
        $this->error = $error;

        $promisor = $this->readPromisor;

Equals sign not aligned with surrounding assignments; expected 11 spaces but found 1 space

        $this->readPromisor = null;

        if ($promisor !== null) {
            $promisor->fail($error);
        }
    }

    public function read(): Promise
    {
        if ($this->error !== null) {
            return new Failure($this->error);
        }

        if ($this->ended) {
            return new Success(null);
        }

        if (count($this->buffer) > 0) {
            return new Success(\array_shift($this->buffer));
        }

        if ($this->readPromisor === null) {
            $this->readPromisor = new Deferred;
        }

        return $this->readPromisor->promise();
    }

    public function close()
    {
        $this->end(); // todo

Comment refers to a TODO task

    }
}