Lines Matching refs:pump

12  * AsyncReadStream can also be used in a "blocking" manner if a "pump" function
14  * buffer, then the pump function is used to block until the requested number
16  * timed-out. This behavior isn't strictly "blocking" because the pump function
30     private $pump;
54      * - pump: (callable) A function that accepts the number of bytes to read
82         static $callables = ['pump', 'drain'];
125      * - pump: (callable) See constructor documentation.
198         // If a pump was provided, the buffer is still open, and not enough
200         if ($this->pump && $resultLen < $length) {
201             $pumpFn = $this->pump;