iframe-proxy | Sunbelt Computer Software

62 lines (50 loc) · 1.27 KB

declare(strict_types=1);
namespace Docker\Stream;
use Psr\Http\Message\StreamInterface;
abstract class CallbackStream
    protected $stream;
    private $onNewFrameCallables = [];
    public function __construct(StreamInterface $stream)
        $this->stream = $stream;
     * Called when there is a new frame from the stream.
     * @param callable $onNewFrame
    public function onFrame(callable $onNewFrame): void
        $this->onNewFrameCallables[] = $onNewFrame;
     * Read a frame in the stream.
     * @return mixed
    abstract protected function readFrame();
     * Wait for stream to finish and call callables if defined.
    public function wait(): void
        while (!$this->stream->eof()) {
            $frame = $this->readFrame();
            if (null !== $frame) {
                if (!\is_array($frame)) {
                    $frame = [$frame];
                foreach ($this->onNewFrameCallables as $newFrameCallable) {
                    \call_user_func_array($newFrameCallable, $frame);
    public function closeAndRead(): void
        $this->stream->close();
        $this->wait();

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

CallbackStream.php

Latest commit

History

CallbackStream.php

File metadata and controls