AliceMajere / wonderland-thread

tests/unit/Mediator/Listener/ListenerTest.php

Indentation +18 added lines, -18 removed lines

@@ -13,26 +13,26 @@
  */
 class ListenerTest extends TestCase
 {
-	/** @var Listener */
-	private $listener;
+    /** @var Listener */
+    private $listener;
 
-	/** @var callable */
-	private $callback;
+    /** @var callable */
+    private $callback;
 
-	public function setUp()
-	{
-		$this->callback = function(){
-  };
-		$this->listener = new Listener(Event::POOL_NEW_THREAD, $this->callback);
-	}
+    public function setUp()
+    {
+        $this->callback = function(){
+    };
+        $this->listener = new Listener(Event::POOL_NEW_THREAD, $this->callback);
+    }
 
-	public function test_listener()
-	{
-		$this->assertSame(Event::POOL_NEW_THREAD, $this->listener->getEventName());
-		$this->assertSame($this->listener, $this->listener->setEventName(Event::POOL_POST_WAIT_TICK));
-		$this->assertSame(Event::POOL_POST_WAIT_TICK, $this->listener->getEventName());
-		$this->assertSame($this->listener, $this->listener->setCallback($this->callback));
-		$this->listener->notify(new Event('test'));
-	}
+    public function test_listener()
+    {
+        $this->assertSame(Event::POOL_NEW_THREAD, $this->listener->getEventName());
+        $this->assertSame($this->listener, $this->listener->setEventName(Event::POOL_POST_WAIT_TICK));
+        $this->assertSame(Event::POOL_POST_WAIT_TICK, $this->listener->getEventName());
+        $this->assertSame($this->listener, $this->listener->setCallback($this->callback));
+        $this->listener->notify(new Event('test'));
+    }
 
 }

tests/unit/Mediator/MediatorTest.php

Indentation +18 added lines, -18 removed lines

@@ -14,25 +14,25 @@
  */
 class MediatorTest extends TestCase
 {
-	/** @var Mediator */
-	private $mediator;
+    /** @var Mediator */
+    private $mediator;
 
-	public function setUp()
-	{
-		$this->mediator = new Mediator();
-	}
+    public function setUp()
+    {
+        $this->mediator = new Mediator();
+    }
 
-	public function test_listeners()
-	{
-		$listener = new Listener(Event::POOL_NEW_THREAD, function() {
-  });
-		$this->assertSame([], $this->mediator->getListeners());
-		$this->assertSame($this->mediator, $this->mediator->addListener($listener));
-		$this->assertSame([Event::POOL_NEW_THREAD => [$listener]], $this->mediator->getListeners());
-		$this->assertSame($this->mediator, $this->mediator->removeListener(new Listener('fake', function(){
-  })));
-		$this->mediator->notify(Event::POOL_NEW_THREAD, new Event('unit-event'));
-		$this->assertSame($this->mediator, $this->mediator->removeListener($listener));
-	}
+    public function test_listeners()
+    {
+        $listener = new Listener(Event::POOL_NEW_THREAD, function() {
+    });
+        $this->assertSame([], $this->mediator->getListeners());
+        $this->assertSame($this->mediator, $this->mediator->addListener($listener));
+        $this->assertSame([Event::POOL_NEW_THREAD => [$listener]], $this->mediator->getListeners());
+        $this->assertSame($this->mediator, $this->mediator->removeListener(new Listener('fake', function(){
+    })));
+        $this->mediator->notify(Event::POOL_NEW_THREAD, new Event('unit-event'));
+        $this->assertSame($this->mediator, $this->mediator->removeListener($listener));
+    }
 
 }

tests/unit/ThreadPoolTest.php

Indentation +86 added lines, -86 removed lines

@@ -17,96 +17,96 @@
  */
 class ThreadPoolTest extends TestCase
 {
-	/** @var ThreadPool */
-	private $threadPool;
-
-	protected function setUp()
-	{
-		$this->threadPool = new ThreadPool();
-	}
-
-	public function test_constructor_destructor()
-	{
-		$this->assertAttributeEquals([], 'threads', $this->threadPool);
-		$this->assertAttributeEquals([], 'runningThreads', $this->threadPool);
-		$this->assertAttributeEquals([], 'toRunThreads', $this->threadPool);
-		$this->assertAttributeEquals(false, 'isRunning', $this->threadPool);
-		$this->assertAttributeEquals(0, 'maxRunningThreadNb', $this->threadPool);
-		$this->assertSame(Mediator::class, get_class($this->threadPool->getMediator()));
-
-		unset($this->threadPool);
-	}
-
-	public function test_getThreads()
-	{
-		$threads = [new Thread()];
-		$this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
-		$this->assertSame($threads, $this->threadPool->getThreads());
-	}
-
-	public function test_addThread()
-	{
-		$thread = new Thread();
-		$this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
-		$this->assertContains($thread, $this->threadPool->getThreads());
-	}
-
-	public function test_getMaxRunningThreadNb()
-	{
-		$this->assertSame(0, $this->threadPool->getMaxRunningThreadNb());
-	}
-
-	public function test_setMaxRunningThreadNb()
-	{
-		$this->assertSame($this->threadPool, $this->threadPool->setMaxRunningThreadNb(10));
-		$this->assertSame(10, $this->threadPool->getMaxRunningThreadNb());
-	}
-
-	public function test_getToRunThreads()
-	{
-		$this->assertSame([], $this->threadPool->getToRunThreads());
-	}
-
-	public function test_getRunningThreads()
-	{
-		$this->assertSame([], $this->threadPool->getRunningThreads());
-	}
-
-	/**
-	 * @throws \Wonderland\Thread\Exception\ThreadException
-	 */
-	public function test_run()
-	{
-		$thread = new Thread();
-		$thread->setCallback(function (){ return 0;
-
-  });
-		$thread->setProcessName('unitTest');
-		$threads = [];
-		$listener = new Listener(Event::POOL_NEW_THREAD, function (){
-  });
-
-		$this->threadPool->setMaxRunningThreadNb(10);
-		$this->assertSame($this->threadPool, $this->threadPool->addListener($listener));
-		for ($i = 0; $i < 20;
+    /** @var ThreadPool */
+    private $threadPool;
+
+    protected function setUp()
+    {
+        $this->threadPool = new ThreadPool();
+    }
+
+    public function test_constructor_destructor()
+    {
+        $this->assertAttributeEquals([], 'threads', $this->threadPool);
+        $this->assertAttributeEquals([], 'runningThreads', $this->threadPool);
+        $this->assertAttributeEquals([], 'toRunThreads', $this->threadPool);
+        $this->assertAttributeEquals(false, 'isRunning', $this->threadPool);
+        $this->assertAttributeEquals(0, 'maxRunningThreadNb', $this->threadPool);
+        $this->assertSame(Mediator::class, get_class($this->threadPool->getMediator()));
+
+        unset($this->threadPool);
+    }
+
+    public function test_getThreads()
+    {
+        $threads = [new Thread()];
+        $this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
+        $this->assertSame($threads, $this->threadPool->getThreads());
+    }
+
+    public function test_addThread()
+    {
+        $thread = new Thread();
+        $this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
+        $this->assertContains($thread, $this->threadPool->getThreads());
+    }
+
+    public function test_getMaxRunningThreadNb()
+    {
+        $this->assertSame(0, $this->threadPool->getMaxRunningThreadNb());
+    }
+
+    public function test_setMaxRunningThreadNb()
+    {
+        $this->assertSame($this->threadPool, $this->threadPool->setMaxRunningThreadNb(10));
+        $this->assertSame(10, $this->threadPool->getMaxRunningThreadNb());
+    }
+
+    public function test_getToRunThreads()
+    {
+        $this->assertSame([], $this->threadPool->getToRunThreads());
+    }
+
+    public function test_getRunningThreads()
+    {
+        $this->assertSame([], $this->threadPool->getRunningThreads());
+    }
+
+    /**
+     * @throws \Wonderland\Thread\Exception\ThreadException
+     */
+    public function test_run()
+    {
+        $thread = new Thread();
+        $thread->setCallback(function (){ return 0;
+
+    });
+        $thread->setProcessName('unitTest');
+        $threads = [];
+        $listener = new Listener(Event::POOL_NEW_THREAD, function (){
+    });
+
+        $this->threadPool->setMaxRunningThreadNb(10);
+        $this->assertSame($this->threadPool, $this->threadPool->addListener($listener));
+        for ($i = 0; $i < 20;
 $i++) { $threads[] = clone $thread;
-		}
-		$this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
-		$this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
+        }
+        $this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
+        $this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
 
-		$this->threadPool->run();
+        $this->threadPool->run();
 
-		$this->assertSame($this->threadPool, $this->threadPool->removeListener($listener));
-	}
+        $this->assertSame($this->threadPool, $this->threadPool->removeListener($listener));
+    }
 
-	/**
-	 * @throws ThreadException
-	 */
-	public function test_run_exception()
-	{
-		$this->expectException(ThreadException::class);
-		$this->threadPool->run();
+    /**
+     * @throws ThreadException
+     */
+    public function test_run_exception()
+    {
+        $this->expectException(ThreadException::class);
+        $this->threadPool->run();
 
-	}
+    }
 
 }

tests/unit/Factory/ThreadFactoryTest.php

Indentation +10 added lines, -10 removed lines

@@ -14,16 +14,16 @@
 class ThreadFactoryTest extends TestCase
 {
 
-	public function test_create()
-	{
-		$callback = function(){
-  };
-		$thread = new Thread();
-		$thread->setProcessName('unit-test');
-		$thread->setCallback($callback);
+    public function test_create()
+    {
+        $callback = function(){
+    };
+        $thread = new Thread();
+        $thread->setProcessName('unit-test');
+        $thread->setCallback($callback);
 
-		$this->assertSame($thread->getCallback(), ThreadFactory::create('unit-test', $callback)->getCallback());
-		$this->assertSame($thread->getProcessName(), ThreadFactory::create('unit-test', $callback)->getProcessName());
-	}
+        $this->assertSame($thread->getCallback(), ThreadFactory::create('unit-test', $callback)->getCallback());
+        $this->assertSame($thread->getProcessName(), ThreadFactory::create('unit-test', $callback)->getProcessName());
+    }
 
 }

tests/unit/ThreadTest.php

Indentation +73 added lines, -73 removed lines

@@ -13,78 +13,78 @@
  */
 class ThreadTest extends TestCase
 {
-	/** @var Thread */
-	private $thread;
-
-	private $callback;
-
-	public function setUp()
-	{
-		$this->callback = function (){ return 0;
-
-  };
-
-		$this->thread = new Thread();
-		$this->thread->setPid(1);
-		$this->thread->setProcessName('unit-test');
-		$this->thread->setCallback($this->callback);
-	}
-
-	public function test_pid()
-	{
-		$this->assertSame(1, $this->thread->getPid());
-		$this->assertSame($this->thread, $this->thread->setPid(100));
-		$this->assertSame(100, $this->thread->getPid());
-	}
-
-	public function test_processName()
-	{
-		$this->assertSame('unit-test', $this->thread->getProcessName());
-		$this->assertSame($this->thread, $this->thread->setProcessName('unit'));
-		$this->assertSame('unit', $this->thread->getProcessName());
-	}
-
-	public function test_callback()
-	{
-		$callback = function(){ return 1;
-
-  };
-
-		$this->assertSame($this->callback, $this->thread->getCallback());
-		$this->assertSame($this->thread, $this->thread->setCallback($callback));
-		$this->assertSame($callback, $this->thread->getCallback());
-	}
-
-	/**
-	 * @throws ThreadException
-	 */
-	public function test_run()
-	{
-		$this->assertSame(0, $this->thread->run('unit-test'));
-	}
-
-	/**
-	 * @throws ThreadException
-	 */
-	public function test_run_exception()
-	{
-		$this->expectException(ThreadException::class);
-		$thread = new Thread();
-		$thread->run('unit-test');
-
-	}
-
-	/**
-	 * @throws ThreadException
-	 */
-	public function test_run_exception_status()
-	{
-		$this->expectException(ThreadException::class);
-		$thread = new Thread();
-		$thread->setCallback(function() { return null;
-
-  });
-		$thread->run('unit-test');
-	}
+    /** @var Thread */
+    private $thread;
+
+    private $callback;
+
+    public function setUp()
+    {
+        $this->callback = function (){ return 0;
+
+    };
+
+        $this->thread = new Thread();
+        $this->thread->setPid(1);
+        $this->thread->setProcessName('unit-test');
+        $this->thread->setCallback($this->callback);
+    }
+
+    public function test_pid()
+    {
+        $this->assertSame(1, $this->thread->getPid());
+        $this->assertSame($this->thread, $this->thread->setPid(100));
+        $this->assertSame(100, $this->thread->getPid());
+    }
+
+    public function test_processName()
+    {
+        $this->assertSame('unit-test', $this->thread->getProcessName());
+        $this->assertSame($this->thread, $this->thread->setProcessName('unit'));
+        $this->assertSame('unit', $this->thread->getProcessName());
+    }
+
+    public function test_callback()
+    {
+        $callback = function(){ return 1;
+
+    };
+
+        $this->assertSame($this->callback, $this->thread->getCallback());
+        $this->assertSame($this->thread, $this->thread->setCallback($callback));
+        $this->assertSame($callback, $this->thread->getCallback());
+    }
+
+    /**
+     * @throws ThreadException
+     */
+    public function test_run()
+    {
+        $this->assertSame(0, $this->thread->run('unit-test'));
+    }
+
+    /**
+     * @throws ThreadException
+     */
+    public function test_run_exception()
+    {
+        $this->expectException(ThreadException::class);
+        $thread = new Thread();
+        $thread->run('unit-test');
+
+    }
+
+    /**
+     * @throws ThreadException
+     */
+    public function test_run_exception_status()
+    {
+        $this->expectException(ThreadException::class);
+        $thread = new Thread();
+        $thread->setCallback(function() { return null;
+
+    });
+        $thread->run('unit-test');
+    }
 
 }

tests/unit/Event/EventTest.php

Indentation +38 added lines, -38 removed lines

@@ -13,43 +13,43 @@
  */
 class EventTest extends TestCase
 {
-	/** @var Event */
-	private $event;
-
-	/** @var Thread */
-	private $thread;
-
-	public function setUp()
-	{
-		$this->thread = new Thread();
-		$this->event = new Event('unit-test');
-		$this->event->setThread($this->thread);
-	}
-
-	public function test_event()
-	{
-		$this->assertSame('unit-test', $this->event->getEventName());
-		$this->assertSame(0, $this->event->getMaxRunningThreadNb());
-		$this->assertSame(0, $this->event->getRunningThreadNb());
-		$this->assertSame(0, $this->event->getThreadDoneNb());
-		$this->assertSame(0, $this->event->getThreadLeftNb());
-		$this->assertSame(0, $this->event->getThreadNb());
-		$this->assertSame($this->thread, $this->event->getThread());
-
-		$this->assertSame($this->event, $this->event->setThread($this->thread));
-		$this->assertSame($this->event, $this->event->setMaxRunningThreadNb(100));
-		$this->assertSame($this->event, $this->event->setEventName('fake'));
-		$this->assertSame($this->event, $this->event->setRunningThreadNb(10));
-		$this->assertSame($this->event, $this->event->setThreadDoneNb(90));
-		$this->assertSame($this->event, $this->event->setThreadLeftNb(10));
-		$this->assertSame($this->event, $this->event->setThreadNb(10));
-
-		$this->assertSame('fake', $this->event->getEventName());
-		$this->assertSame(100, $this->event->getMaxRunningThreadNb());
-		$this->assertSame(10, $this->event->getRunningThreadNb());
-		$this->assertSame(90, $this->event->getThreadDoneNb());
-		$this->assertSame(10, $this->event->getThreadLeftNb());
-		$this->assertSame(10, $this->event->getThreadNb());
-	}
+    /** @var Event */
+    private $event;
+
+    /** @var Thread */
+    private $thread;
+
+    public function setUp()
+    {
+        $this->thread = new Thread();
+        $this->event = new Event('unit-test');
+        $this->event->setThread($this->thread);
+    }
+
+    public function test_event()
+    {
+        $this->assertSame('unit-test', $this->event->getEventName());
+        $this->assertSame(0, $this->event->getMaxRunningThreadNb());
+        $this->assertSame(0, $this->event->getRunningThreadNb());
+        $this->assertSame(0, $this->event->getThreadDoneNb());
+        $this->assertSame(0, $this->event->getThreadLeftNb());
+        $this->assertSame(0, $this->event->getThreadNb());
+        $this->assertSame($this->thread, $this->event->getThread());
+
+        $this->assertSame($this->event, $this->event->setThread($this->thread));
+        $this->assertSame($this->event, $this->event->setMaxRunningThreadNb(100));
+        $this->assertSame($this->event, $this->event->setEventName('fake'));
+        $this->assertSame($this->event, $this->event->setRunningThreadNb(10));
+        $this->assertSame($this->event, $this->event->setThreadDoneNb(90));
+        $this->assertSame($this->event, $this->event->setThreadLeftNb(10));
+        $this->assertSame($this->event, $this->event->setThreadNb(10));
+
+        $this->assertSame('fake', $this->event->getEventName());
+        $this->assertSame(100, $this->event->getMaxRunningThreadNb());
+        $this->assertSame(10, $this->event->getRunningThreadNb());
+        $this->assertSame(90, $this->event->getThreadDoneNb());
+        $this->assertSame(10, $this->event->getThreadLeftNb());
+        $this->assertSame(10, $this->event->getThreadNb());
+    }
 
 }

tests/bootstrap.php

Indentation +2 added lines, -2 removed lines

@@ -2,7 +2,7 @@ 
 declare( strict_types = 1 );
 
 if ( PHP_SAPI !== 'cli' ) {
-	die( 'Not an entry point' );
+    die( 'Not an entry point' );
 }
 
 error_reporting( -1 );
@@ -10,7 +10,7 @@ 
 ini_set( 'display_errors', '1' );
 
 if ( !is_readable( __DIR__ . '/../vendor/autoload.php' ) ) {
-	die( 'You need to install this package with Composer before you can run the tests' );
+    die( 'You need to install this package with Composer before you can run the tests' );
 }
 
 require_once __DIR__ . '/../vendor/autoload.php';