fixed ListenerProviderInterface stuff

composer.json

@@ -2,7 +2,7 @@
   "name": "phoole/event",
   "type": "library",
   "license": "Apache-2.0",
-  "version": "1.0.3",
+  "version": "1.0.5",
   "description": "A slim PSR-14 event implementation",
   "keywords": [
     "phoole",

src/Dispatcher.php

@@ -14,7 +14,6 @@
 use Phoole\Base\Queue\UniquePriorityQueue;
 use Psr\EventDispatcher\StoppableEventInterface;
 use Psr\EventDispatcher\EventDispatcherInterface;
-use Psr\EventDispatcher\ListenerProviderInterface;
 
 /**
  * Dispatcher
@@ -24,16 +23,16 @@
 class Dispatcher implements EventDispatcherInterface
 {
     /**
-     * @var ListenerProviderInterface[]
+     * @var Provider[]
      */
     protected $providers = [];
 
     /**
      * Dispatcher constructor.
      *
-     * @param  ListenerProviderInterface ...$providers
+     * @param  Provider ...$providers
      */
-    public function __construct(ListenerProviderInterface ...$providers)
+    public function __construct(Provider ...$providers)
     {
         foreach ($providers as $p) {
             $this->addProvider($p);
@@ -63,11 +62,11 @@ public function dispatch(object $event)
     /**
      * Add a provider to the dispatcher
      *
-     * @param  ListenerProviderInterface $provider
+     * @param  Provider $provider
      * @return  void
      * @throws  \RuntimeException  if provider duplicated
      */
-    protected function addProvider(ListenerProviderInterface $provider)
+    protected function addProvider(Provider $provider)
     {
         $hash = \spl_object_hash($provider);
         if (!isset($this->providers[$hash])) {

src/Provider.php

@@ -11,8 +11,8 @@
 
 namespace Phoole\Event;
 
-use Phoole\Base\Queue\PriorityQueue;
 use Phoole\Base\Reflect\ParameterTrait;
+use Phoole\Base\Queue\UniquePriorityQueue;
 use Psr\EventDispatcher\ListenerProviderInterface;
 
 /**
@@ -27,7 +27,7 @@ class Provider implements ListenerProviderInterface
     /**
      * event classes listened
      *
-     * @var PriorityQueue[]
+     * @var UniquePriorityQueue[]
      */
     protected $listened = [];
 
@@ -40,7 +40,7 @@ class Provider implements ListenerProviderInterface
      */
     public function getListenersForEvent(object $event): iterable
     {
-        $queue = new PriorityQueue();
+        $queue = new UniquePriorityQueue();
         foreach ($this->listened as $class => $q) {
             if (is_a($event, $class) && count($q)) {
                 $queue = $queue->combine($q);
@@ -54,15 +54,15 @@ public function getListenersForEvent(object $event): iterable
      *
      * @param  callable $callable  MUST be type-compatible with $event.
      * @param  int      $priority  range 0 - 100, 0 means lower priority
-     * @return ListenerProviderInterface $this
+     * @return $this
      * @throws \RuntimeException            reflection problem found
      * @throws \InvalidArgumentException    unknown type of callable found
      */
-    public function attach(callable $callable, int $priority = 50): ListenerProviderInterface
+    public function attach(callable $callable, int $priority = 50)
     {
         $class = $this->getEventClass($callable);
         if (!isset($this->listened[$class])) {
-            $this->listened[$class] = new PriorityQueue();
+            $this->listened[$class] = new UniquePriorityQueue();
         }
         $this->listened[$class]->insert($callable, $priority);
         return $this;
@@ -80,12 +80,14 @@ protected function getEventClass(callable $callable): string
     {
         try {
             $params = $this->getCallableParameters($callable);
-
             $error = 'Listener must declare one object as event';
+
+            // only one parameter allowed
             if (1 != count($params)) {
                 throw new \InvalidArgumentException($error);
             }
 
+            // must be object
             $type = $params[0]->getType()->getName();
             if (class_exists($type) || interface_exists($type)) {
                 return $type;