Yiisoft\Yii\Debug\Api\ServerSentEventsStream

Complexity

Total Complexity

18

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	read()	0	15	3
A	getSize()	0	3	1
A	isSeekable()	0	3	1
A	isWritable()	0	3	1
A	detach()	0	3	1
A	__toString()	0	3	1
A	rewind()	0	3	1
A	seek()	0	3	1
A	close()	0	3	1
A	isReadable()	0	3	1
A	getContents()	0	3	1
A	getMetadata()	0	3	1
A	write()	0	3	1
A	__construct()	0	3	1
A	eof()	0	3	1
A	tell()	0	3	1

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\Api;

use Closure;
use Psr\Http\Message\StreamInterface;

final class ServerSentEventsStream implements StreamInterface, \Stringable
{
    public array $buffer = [];
    private bool $eof = false;

    public function __construct(
        private Closure $stream,
    ) {
    }

    public function close(): void
    {
        $this->eof = true;
    }

    public function detach(): void
    {
        $this->eof = true;
    }

    public function getSize()
    {
        return null;
    }

    public function tell(): int
    {
        return 0;
    }

    public function eof(): bool
    {
        return $this->eof;
    }

    public function isSeekable(): bool
    {
        return false;
    }

    public function seek($offset, $whence = SEEK_SET): void
    {
        throw new \RuntimeException('Stream is not seekable');
    }

    public function rewind(): void
    {
        throw new \RuntimeException('Stream is not seekable');
    }

    public function isWritable(): bool
    {
        return false;
    }

    public function write($string): void
    {
        throw new \RuntimeException('Stream is not writable');
    }

    public function isReadable(): bool
    {
        return true;
    }

    /**
     * TODO: support length reading
     */
    public function read(int $length): string
    {
        $continue = ($this->stream)($this->buffer);

        if (!$continue) {
            $this->eof = true;
        }

        $output = '';
        foreach ($this->buffer as $key => $value) {
            unset($this->buffer[$key]);
            $output .= sprintf("data: %s\n", $value);
        }
        $output .= "\n";
        return $output;
    }

    public function getContents(): string
    {
        return $this->read(1024);
    }

    public function getMetadata($key = null): array
    {
        return [];
    }

    public function __toString(): string
    {
        return $this->getContents();
    }
}