Extraload\Extractor\QueuedExtractor

Complexity

Total Complexity

3

Size/Duplication

Total Lines	20
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	4
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	6	6	1
A	extract()	6	6	2

<?php

namespace Extraload\Extractor;

use Ko\AmqpBroker;

class QueuedExtractor implements ExtractorInterface
{
    private $extractor;
    private $broker;
    private $proucer;

    public function __construct(ExtractorIteratorInterface $extractor, AmqpBroker $broker, $proucer)
    {
        $this->extractor = $extractor;
        $this->broker = $broker;
        $this->proucer = $proucer;
    }

    public function extract()
    {
        while (null !== $extracted = $this->extractor->extract()) {
            $this->broker->getProducer($this->proucer)->publish(serialize($extracted));
        }
    }
}