Carno\Pool\Wrapper\SAR::sarRun()

Complexity

Conditions	5
Paths	2

Size

Total Lines	29
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function sarRun(Pool $pool, string $method, array $arguments, Promised $interrupter = null)
    {
        /**
         * @var Poolable $conn
         */
        $conn = null;

        // MUST use defer because it can exec whatever job be FIN or KILL
        // otherwise conn will never be released
        yield defer(function ($stage) use (&$conn) {
            if ($conn instanceof Poolable) {
                $stage instanceof Broken ? $conn->destroy() : $conn->release();
            } elseif ($stage instanceof Poolable) {
                $stage->release();
            }
        });

        // pick out
        $conn = yield $pool->select();

        // check interrupter
        if ($interrupter) {
            $interrupter->then(function () use ($conn) {
                return $conn;
            });
        }

        // execute
        return yield $conn->$method(...$arguments);
    }