src/RequestHandler.php
public function handle(ConnectionInterface $incoming)
    {
        $this->incoming = $incoming;

        $this->incoming->on('data', [$this, 'handleData']);
        $this->incoming->on('close', function () {
            $this->connectionOpen = false;
        });

        $this->start = microtime(true);
        $this->requestSentAt = microtime(true);
        $this->getNextSlave();

        if ($this->maxExecutionTime > 0) {
            $this->maxExecutionTimer = $this->loop->addTimer($this->maxExecutionTime, [$this, 'maxExecutionTimeExceeded']);
        }
    }
public function handle(ConnectionInterface $incoming)
    {
        $this->incoming = $incoming;

        $this->incoming->on('data', [$this, 'handleData']);
        $this->incoming->on('close', function () {
            $this->connectionOpen = false;
        });

        $this->start = microtime(true);
        $this->requestSentAt = microtime(true);
        $this->getNextSlave();

        if ($this->maxExecutionTime > 0) {
            $this->maxExecutionTimer = $this->loop->addTimer($this->maxExecutionTime, [$this, 'maxExecutionTimeExceeded']);
        }
    }
public function handle ( ConnectionInterface $ incoming ) { $ this -> incoming = $ incoming ; $ this -> incoming -> on ( 'data' , [ $ this , 'handleData' ] ) ; $ this -> incoming -> on ( 'close' , function ( ) { $ this -> connectionOpen = false ; } ) ; $ this -> start = microtime ( true ) ; $ this -> requestSentAt = microtime ( true ) ; $ this -> getNextSlave ( ) ; if ( $ this -> maxExecutionTime > 0 ) { $ this -> maxExecutionTimer = $ this -> loop -> addTimer ( $ this -> maxExecutionTime , [ $ this , 'maxExecutionTimeExceeded' ] ) ; } }
Handle incoming client connection

@param ConnectionInterface $incoming
Handle incoming client connection