Raigu\OrderedDataSynchronization\Synchronization::__invoke()

Complexity

Conditions	7
Paths	6

Size

Total Lines	32
Code Lines	27

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function __invoke(Iterator $source, Iterator $target, callable $add, callable $remove)
    {
        $s = $source->current();
        $t = $target->current();

        while (!is_null($s) or !is_null($t)) {
            if (is_null($t)) {
                // Reached at the end of target. Add all reminding source elements.
                $add($s);
                $source->next();
                $s = $source->current();
            } else if (is_null($s)) {
                // Reached at the end of source. Remove all remaining target elements.
                $remove($t);
                $target->next();
                $t = $target->current();
            } else {
                $sv = strval($s);
                $tv = strval($t);
                if ($sv === $tv) {
                    $source->next();
                    $s = $source->current();
                    $target->next();
                    $t = $target->current();
                } else if ($sv < $tv) {
                    $add($s);
                    $source->next();
                    $s = $source->current();
                } else { // $s > $t
                    $remove($t);
                    $target->next();
                    $t = $target->current();
                }
}