Pool::add() - Code Metrics - vuongxuongminh/laravel-async - Measure and Improve Code Quality continuously with Scrutinizer

Pool::add() A
last analyzed 2021-02-07 04:27 UTC

↳ Parent: Pool

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	14
rs	9.7998
c	0
b	0
f	0
cc	2
nc	2
nop	2

<?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 <[email protected]>
 * @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;
    }
}


1			<?php
2			/**
3			* @link https://github.com/vuongxuongminh/laravel-async
4			*
5			* @copyright (c) Vuong Xuong Minh
6			* @license [MIT](https://opensource.org/licenses/MIT)
7			*/
8
9			namespace VXM\Async;
10
11			use Spatie\Async\Pool as BasePool;
12			use Spatie\Async\Process\Runnable;
13			use VXM\Async\Runtime\ParentRuntime;
14
15			/**
16			* @author Vuong Minh <[email protected]>
17			* @since 1.0.0
18			*/
19			class Pool extends BasePool
20			{
21			/**
22			* Default processes output length.
23			*
24			* @var int
25			*/
26			protected $defaultOutputLength = 10240;
27
28			/**
29			* Flush the pool.
30			*/
31			public function flush(): void
32			{
33			$this->inProgress = [];
34			$this->timeouts = [];
35			$this->finished = [];
36			$this->queue = [];
37			$this->failed = [];
38			$this->results = [];
39			}
40
41			/**
42			* @inheritDoc
43			*/
44			public function add($process, int $outputLength = null): Runnable
45			{
46			$outputLength = $outputLength ?? $this->defaultOutputLength;
47
48			if (is_callable($process)) {
49			$process = ParentRuntime::createProcess(
50			$process,
51			$outputLength,
52			$this->binary
53			);
54			}
55
56			return parent::add($process, $outputLength);
57			}
58
59			/**
60			* Set default output length of child processes.
61			*
62			* @param int $defaultOutputLength
63			* @since 2.1.0
64			*/
65			public function defaultOutputLength(int $defaultOutputLength): void
66			{
67			$this->defaultOutputLength = $defaultOutputLength;
68			}
69			}
70

vuongxuongminh / laravel-async

Pool::add() A last analyzed 2021-02-07 04:27 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Pool::add() A
last analyzed 2021-02-07 04:27 UTC