Transfer\Processor\SequentialProcessor::handleProcedure()

Complexity

Conditions	3
Paths	3

Size

Total Lines

21

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	3

Importance

Changes

0

<?php
    protected function handleProcedure(Procedure $procedure)
    {
        foreach ((array) $procedure->getSources() as $source) {
            list($adapter, $request) = $source;

            $response = $this->handleSource($adapter, $request);

            $response->getIterator()->rewind();

            while ($object = $this->nextObject($response->getIterator())) {

                $storage = $this->prepareLocalStorage($object);

                $this->handleWorkers($procedure->getWorkers(), $storage);

                $this->handleTargets($procedure->getTargets(), new Request($storage->all()));

                $this->mergeStorage($storage);
            }
        }
    }
}