mpyw\HyperBuiltinServer\Internal\ConnectionHandler::__invoke()

Complexity

Conditions	2
Paths	1

Size

Total Lines

20

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function __invoke(ConnectionInterface $conn)
    {
        $sink = new Sink($conn);
        $this->master->queue->executeAsync(function (BuiltinServer $process) use ($conn, $sink) {
            $deferred = new Deferred;
            try {
                $child = new Stream($process->getSocketClient(), $this->master->loop);
                $sink->pipe($child);
                $child->pipe($conn);
                $child->on('close', function () use ($deferred) {
                    $deferred->resolve();
                });
            } catch (\RuntimeException $e) {
                $conn->write("HTTP/1.0 502 Bad Gateway\r\n");
                $conn->end("\r\n");
                $deferred->resolve();
            }
            return $deferred->promise();
        });
    }
}