SlowPlusJob.php

Go to the documentation of this file.

<?php

namespace ILIAS\BackgroundTasks\Implementation\Tasks;

use ILIAS\BackgroundTasks\Implementation\Bucket\BucketMock;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\IntegerValue;
use ILIAS\BackgroundTasks\Observer;
use ILIAS\BackgroundTasks\Value;
use ILIAS\BackgroundTasks\Types\SingleType;
use ILIAS\BackgroundTasks\Types\Type;

class SlowPlusJob extends AbstractJob
{
    const SLEEP_SECONDS = 10;


    public function __construct()
    {
    }


    public function getInputTypes()
    {
        return [
            new SingleType(IntegerValue::class),
            new SingleType(IntegerValue::class),
        ];
    }


    public function getOutputType()
    {
        return new SingleType(IntegerValue::class);
    }


    public function run(array $input, Observer $observer)
    {
        $a = $input[0];
        $b = $input[1];

        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 20);
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 40);
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 60);
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 80);

        $output = new IntegerValue();
        $output->setValue($a->getValue() + $b->getValue());

        return $output;
    }


    public function isStateless()
    {
        return true;
    }

    public function getExpectedTimeOfTaskInSeconds()
    {
        return 2;
    }
}