mpyw\HyperBuiltinServer\Internal\Sink::__construct()

Complexity

Conditions	4
Paths	1

Size

Total Lines

23

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function __construct(ConnectionInterface $src)
    {
        $this->src = $src;
        $src->on('data', function ($data) {
            $this->buffer .= $data;
            if ($this->dst) {
                $this->dst->write($this->buffer);
                $this->buffer = '';
            }
        });
        $src->on('end', function () {
            $this->end = true;
            if ($this->dst) {
                $this->dst->end();
            }
        });
        $src->on('error', function () {
            $this->end = true;
            if ($this->dst) {
                $this->dst->end();
            }
        });
    }