protected function fill()
    {
        if (count($this) <= 0) {
            return;
        }

        $read = $this->sockets;
        $write = null;
        $except = null;
        $time = count($this->results) > 0 ? 0 : $this->timeout;

        if (stream_select($read, $write, $except, $time) > 0) {
            foreach ($read as $socket) {
                try {
                    $result = $this->read($socket);
                } catch (\RuntimeException $e) {
                    continue;
                }
                $this->results->enqueue($result);
                $this->remain--;
            }
        }
    }
protected function fill()
    {
        if (count($this) <= 0) {
            return;
        }

        $read = $this->sockets;
        $write = null;
        $except = null;
        $time = count($this->results) > 0 ? 0 : $this->timeout;

        if (stream_select($read, $write, $except, $time) > 0) {
            foreach ($read as $socket) {
                try {
                    $result = $this->read($socket);
                } catch (\RuntimeException $e) {
                    continue;
                }
                $this->results->enqueue($result);
                $this->remain--;
            }
        }
    }
protected function fill ( ) { if ( count ( $ this ) <= 0 ) { return ; } $ read = $ this -> sockets ; $ write = null ; $ except = null ; $ time = count ( $ this -> results ) > 0 ? 0 : $ this -> timeout ; if ( stream_select ( $ read , $ write , $ except , $ time ) > 0 ) { foreach ( $ read as $ socket ) { try { $ result = $ this -> read ( $ socket ) ; } catch ( \ RuntimeException $ e ) { continue ; } $ this -> results -> enqueue ( $ result ) ; $ this -> remain -- ; } } }
Read process results.
Block when results are empty.

@return  void
Read process results . Block when results are empty .