kakserpom / phpdaemon

	 * @param  string   &$buf

	 * @return callable

	 */

	protected function readAllGenHandler($cb, $size, &$offset, &$pri, &$buf) {

		return function ($file, $data) use ($cb, $size, &$offset, &$pri, &$buf) {

			$buf .= $data;

			$offset += strlen($data);

			$len = min($file->chunkSize, $size - $offset);

			if ($offset >= $size) {

				if ($cb) {

					$cb($file, $buf);

				}

				return;

			}

			eio_read($file->fd, $len, $offset, $pri, $this->readAllGenHandler($cb, $size, $offset, $pri, $buf), $this);

		};

	}

	/**

	 * Reads whole file

	 * @param  integer  $pri

	 * @return callable

	 */

	protected function readAllChunkedGenHandler($cb, $chunkcb, $size, &$offset, $pri) {

		return function ($file, $data) use ($cb, $chunkcb, $size, &$offset, $pri) {

			$chunkcb($file, $data);

			$offset += strlen($data);

			$len = min($file->chunkSize, $size - $offset);

			if ($offset >= $size) {

				$cb($file, true);

				return;

			}

			eio_read($file->fd, $len, $offset, $pri, $this->readAllChunkedGenHandler($cb, $chunkcb, $size, $offset, $pri), $file);

		};

	}

	/**

	 * Reads file chunk-by-chunk