Created the CallableTask class. The loop supports callables as tasks

Author: andaniel05

src/CallableTask.php

@@ -0,0 +1,25 @@
+<?php
+declare(strict_types=1);
+
+namespace ThenLabs\TaskLoop;
+
+/**
+ * @author Andy Daniel Navarro Taño <andaniel05@gmail.com>
+ */
+class CallableTask extends AbstractTask
+{
+    /**
+     * @var callable
+     */
+    protected $callable;
+
+    public function __construct(callable $callable)
+    {
+        $this->callable = $callable;
+    }
+
+    public function run(): void
+    {
+        call_user_func($this->callable, $this);
+    }
+}

src/TaskLoop.php

@@ -5,6 +5,7 @@
 
 use SplObjectStorage;
 use Symfony\Component\EventDispatcher\EventDispatcher;
+use TypeError;
 
 /**
  * @author Andy Daniel Navarro Taño <andaniel05@gmail.com>
@@ -42,8 +43,20 @@ public function getTasks(): SplObjectStorage
         return $this->tasks;
     }
 
-    public function addTask(TaskInterface $task): void
+    /**
+     * @param TaskInterface|callable $task
+     * @return void
+     */
+    public function addTask($task): void
     {
+        if (! $task instanceof TaskInterface) {
+            if (is_callable($task)) {
+                $task = new CallableTask($task);
+            } else {
+                throw new TypeError('The task argument should be an instance of TaskInterface or a callable.');
+            }
+        }
+
         $event = new Event\AddTaskEvent($task);
         $this->dispatcher->dispatch($event);
 

tests/test-AbstractTask.php

@@ -21,4 +21,4 @@ public function run(): void
     $loop->addTask($task);
 
     $task->end();
-});
+});

tests/test-TaskLoop.php

@@ -16,6 +16,12 @@
         $this->assertCount(0, $this->loop->getTasks());
     });
 
+    test(function () {
+        $this->expectException(TypeError::class);
+
+        $this->loop->addTask(uniqid());
+    });
+
     test(function () {
         $task1 = $this->getMockBuilder(TaskInterface::class)
             ->setMethods(['run'])
@@ -90,6 +96,19 @@ public function run(): void
         $this->assertCount(3, $task2->invokations);
     });
 
+    test(function () {
+        $executed = false;
+
+        $this->loop->addTask(function ($task) use (&$executed) {
+            $executed = true;
+            $task->end();
+        });
+
+        $this->loop->runTasks();
+
+        $this->assertCount(0, $this->loop->getTasks());
+    });
+
     test(function () {
         $this->loop->getDispatcher()->addListener(RunTaskEvent::class, function (RunTaskEvent $event) {
             $event->getTask()->runned = new DateTime();