Async\AsyncProcess::startJob()

Complexity

Conditions	5
Paths	1

Size

Total Lines	23
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php
    public function startJob(
        callable $callback = null,
        callable $onError = null
    ): void {
        $this->hasCallbackSet = null !== $callback;
        $this->hasOnErrorSet = null !== $callback;

        $this->start(
            static function (string $type, string $buffer) use ($callback, $onError) {
                // if we can't decode probably child failed to execute
                if ($decoded = base64_decode($buffer, true)) {
                    /** @var AsyncChildResponse $asyncChildResponse */
                    $asyncChildResponse = unserialize($decoded, [false]);
                } else {
                    throw new RuntimeException('Child process returned: ' . $buffer);
                }

                if (null !== $onError && $asyncChildResponse->getError()) {
                    $onError($asyncChildResponse->getError());
                }

                if (null !== $callback) {
                    $callback($asyncChildResponse->getJobResult(), $asyncChildResponse->getStdOut());
                }
}