Gica\Cqrs\Command\CommandDispatcher\ConcurrentProofFunctionCaller::executeFunction()

Complexity

Conditions	4
Paths	3

Size

Total Lines	25
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	10
CRAP Score	4

Importance

Changes

0

<?php
    public function executeFunction($pureFunction, $maxRetries, array $arguments = [])
    {
        $retries = -1;
        do {
            try {

                /**
                 * The real function call
                 */
                return call_user_func_array($pureFunction, $arguments);

            } catch (ConcurrentModificationException $e) {

                $retries++;
                if ($retries >= $maxRetries) {
                    break;
                }

                continue;//retry
            }

        } while (true);

        throw new TooManyCommandExecutionRetries(sprintf("TooManyCommandExecutionRetries: %d (%s)", $retries, $e->getMessage()));
    }
}