Async\AsyncProcess::startJob()

Complexity

Conditions	5
Paths	1

Size

Total Lines	26
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

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

        $this->start(
            function ($type, $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);
                } else {
                    throw new \RuntimeException('Child process returned: ' . $buffer);
                }

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

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

}