Yiisoft\Yii\Debug\Api\Controller\DebugServerController::stream()

Complexity

Conditions	5
Paths	2

Size

Total Lines	33
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	30

Importance

Changes

0

<?php
    public function stream(
        ResponseFactoryInterface $responseFactory
    ): ResponseInterface {
        if (\function_exists('pcntl_signal')) {
            \pcntl_signal(\SIGINT, static function (): void {
                exit(1);

Using exit here is not recommended.

            });
        }

        $socket = Connection::create();
        $socket->bind();

        return $responseFactory->createResponse()
            ->withHeader(Header::CONTENT_TYPE, 'text/event-stream')
            ->withHeader(Header::CACHE_CONTROL, 'no-cache')
            ->withHeader(Header::CONNECTION, 'keep-alive')
            ->withBody(
                new ServerSentEventsStream(function () use ($socket) {
                    foreach ($socket->read() as $message) {
                        switch ($message[0]) {
                            case Connection::TYPE_ERROR:
                                return '';
                            default:
                                /**
                                 * Break the loop if the client aborted the connection (closed the page)
                                 */
                                if (connection_aborted()) {
                                    return $message[1];
                                }
                                yield $message[1];
                        }
                    }
                    return '';
                })