AsyncSockets\RequestExecutor\NativeRequestExecutor

Complexity

Total Complexity

5

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	disconnectItems()	0	4	1
A	initializeRequest()	0	5	1
A	terminateRequest()	0	5	1
A	doExecuteRequest()	0	4	1

<?php
/**
 * Async sockets
 *
 * @copyright Copyright (c) 2015-2017, Efimov Evgenij <edefimov.it@gmail.com>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */

namespace AsyncSockets\RequestExecutor;

use AsyncSockets\Configuration\Configuration;
use AsyncSockets\RequestExecutor\Pipeline\EventCaller;
use AsyncSockets\RequestExecutor\Pipeline\Pipeline;
use AsyncSockets\RequestExecutor\Pipeline\PipelineFactory;

/**
 * Class RequestExecutor
 */
class NativeRequestExecutor extends AbstractRequestExecutor
{
    /**
     * Pipeline
     *
     * @var Pipeline
     */
    private $pipeline;

    /**
     * PipelineFactory
     *
     * @var PipelineFactory
     */
    private $pipelineFactory;

    /**
     * RequestExecutor constructor.
     *
     * @param PipelineFactory $pipelineFactory Pipeline factory
     * @param Configuration   $configuration Configuration for executor
     */
    public function __construct(PipelineFactory $pipelineFactory, Configuration $configuration)
    {
        parent::__construct($configuration);
        $this->pipelineFactory = $pipelineFactory;
    }

    /** {@inheritdoc} */
    protected function initializeRequest(EventCaller $eventCaller, ExecutionContext $executionContext)
    {
        parent::initializeRequest($eventCaller, $executionContext);
        $this->pipeline = $this->pipelineFactory->createPipeline($this, $executionContext, $eventCaller, $this->solver);
    }

    /** {@inheritdoc} */
    protected function terminateRequest(ExecutionContext $executionContext)
    {
        parent::terminateRequest($executionContext);
        $this->pipeline = null;
    }

    /** {@inheritdoc} */
    protected function doExecuteRequest(EventCaller $eventCaller, ExecutionContext $executionContext)
    {
        $this->pipeline->process($this->socketBag);
    }

    /** {@inheritdoc} */
    protected function disconnectItems(array $items)
    {
        $this->pipeline->disconnectSockets($items);
    }
}