Genkgo\Mail\Stream\LazyStream

Complexity

Total Complexity

18

Size/Duplication

Total Lines	159
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

35.9%

Importance

Changes

0

17 Methods

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

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Stream;

use Genkgo\Mail\StreamInterface;

final class LazyStream implements StreamInterface
{
    /**
     * @var \Closure
     */
    private $callback;
    /**
     * @var StreamInterface
     */
    private $decoratedStream;

    /**
     * LazyStream constructor.
     * @param \Closure $callback
     */
    public function __construct(\Closure $callback)
    {
        $this->callback = $callback;
    }

    /**
     * @return string
     */
    public function __toString(): string
    {
        return $this->getStream()->__toString();
    }

    /**
     *
     */
    public function close(): void
    {
        $this->getStream()->close();
    }

    /**
     * @return mixed
     */
    public function detach()
    {
        return $this->getStream()->detach();
    }

    /**
     * @return int|null
     */
    public function getSize(): ?int
    {
        return $this->getStream()->getSize();
    }

    /**
     * @return int
     * @throws \RuntimeException
     */
    public function tell(): int
    {
        return $this->getStream()->tell();
    }

    /**
     * @return bool
     */
    public function eof(): bool
    {
        return $this->getStream()->eof();
    }

    /**
     * @return bool
     */
    public function isSeekable(): bool
    {
        return $this->getStream()->isSeekable();
    }

    /**
     * @param int $offset
     * @param int $whence
     * @return int
     */
    public function seek(int $offset, int $whence = SEEK_SET): int
    {
        return $this->getStream()->seek($offset, $whence);
    }

    /**
     * @return bool
     */
    public function rewind(): bool
    {
        return $this->getStream()->rewind();
    }

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

    /**
     * @param $string
     * @return int
     */
    public function write($string): int
    {
        throw new \RuntimeException('Cannot write to stream');
    }

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

    /**
     * @param int $length
     * @return string
     */
    public function read(int $length): string
    {
        return $this->getStream()->read($length);
    }

    /**
     * @return string
     */
    public function getContents(): string
    {
        return $this->getStream()->getContents();
    }

    /**
     * @param array $keys
     * @return array
     */
    public function getMetadata(array $keys = []): array
    {
        return $this->getStream()->getMetadata();
    }

    /**
     * @return StreamInterface
     */
    private function getStream(): StreamInterface
    {
        if ($this->decoratedStream === null) {
            $callback = $this->callback;
            $this->decoratedStream = $callback();
        }

        return $this->decoratedStream;
    }
}