VXM\Async\Pool

Complexity

Total Complexity

4

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	flush()	0	9	1
A	add()	0	14	2
A	defaultOutputLength()	0	4	1

<?php
/**
 * @link https://github.com/vuongxuongminh/laravel-async
 *
 * @copyright (c) Vuong Xuong Minh
 * @license [MIT](https://opensource.org/licenses/MIT)
 */

namespace VXM\Async;

use Spatie\Async\Pool as BasePool;
use Spatie\Async\Process\Runnable;
use VXM\Async\Runtime\ParentRuntime;

/**
 * @author Vuong Minh <vuongxuongminh@gmail.com>
 * @since 1.0.0
 */
class Pool extends BasePool
{
    /**
     * Default processes output length.
     *
     * @var int
     */
    protected $defaultOutputLength = 10240;

    /**
     * Flush the pool.
     */
    public function flush(): void
    {
        $this->inProgress = [];
        $this->timeouts = [];
        $this->finished = [];
        $this->queue = [];
        $this->failed = [];
        $this->results = [];
    }

    /**
     * @inheritDoc
     */
    public function add($process, int $outputLength = null): Runnable
    {
        $outputLength = $outputLength ?? $this->defaultOutputLength;

        if (is_callable($process)) {
            $process = ParentRuntime::createProcess(
                $process,
                $outputLength,
                $this->binary
            );
        }

        return parent::add($process, $outputLength);
    }

    /**
     * Set default output length of child processes.
     *
     * @param  int  $defaultOutputLength
     * @since 2.1.0
     */
    public function defaultOutputLength(int $defaultOutputLength): void
    {
        $this->defaultOutputLength = $defaultOutputLength;
    }
}