事件监听器支持：匿名函数和对象实例

Author: ueaner

README.md

@@ -37,8 +37,7 @@ Soli Event Manager
         echo "应用已启动\n";
     });
 
-`监听器的格式`，只要是 [call_user_func_array] 允许的格式即可，
-也可以是包含与事件名称同名的实例化类。
+`监听器的格式`，可以是 `匿名函数或对象实例`。
 
 如，我们这里定义一个 `AppEvents` 类用于处理针对 `Application` 类的事件：
 
@@ -56,11 +55,14 @@ Soli Event Manager
     }
 
     // 注册事件监听
-    $eventManager->on('application:boot', array(new AppEvents, 'boot'));
-    也可以这样：
-    $eventManager->on('application:boot', new AppEvents);
 
-    或 call_user_func_array 支持的其他格式。
+    // 匿名函数
+    $eventManager->on('application:boot', function (Event $event, $application) {
+        echo "应用已启动\n";
+    });
+
+    // 对象实例
+    $eventManager->on('application:boot', new AppEvents);
 
 ### 聚合事件监听器到专门的事件类中进行处理
 
@@ -70,7 +72,7 @@ Soli Event Manager
 
     $eventManager->on('application', new AppEvents);
 
-这样我们便可以很方便的注册和整理不同纬度的不同事件。
+这样我们便可以很方便的注册和整理不同维度的不同事件。
 
 ### 触发事件
 
@@ -97,5 +99,4 @@ Soli Event Manager
 MIT Public License
 
 
-[Phalcon 框架的事件管理器]: https://docs.phalconphp.com/zh/latest/reference/events.html
-[call_user_func_array]: http://cn2.php.net/call_user_func_array
+[Phalcon 框架的事件管理器]: https://docs.phalconphp.com/en/latest/events

src/Events/Event.php

@@ -4,6 +4,8 @@
  */
 namespace Soli\Events;
 
+use Closure;
+
 /**
  * 事件原型
  */
@@ -80,18 +82,12 @@ public function fire($queue)
                 break;
             }
 
-            if (is_callable($listener)) {
+            if ($listener instanceof Closure) {
+                // 调用闭包监听器
                 $status = call_user_func_array($listener, [$this, $this->source, $this->data]);
-            } elseif (is_object($listener)) {
-                if (method_exists($listener, $this->name)) {
-                    // 调用对象监听器
-                    $status = $listener->{$this->name}($this, $this->source, $this->data);
-                }
-            } elseif (is_string($listener) && class_exists($listener)) {
-                // 注意这里的 $this->name 需要是 $listener 的静态方法
-                if (method_exists($listener, $this->name)) {
-                    $status = call_user_func_array([$listener, $this->name], [$this, $this->source, $this->data]);
-                }
+            } elseif (method_exists($listener, $this->name)) {
+                // 调用对象监听器
+                $status = $listener->{$this->name}($this, $this->source, $this->data);
             }
         }
 

src/Events/EventManager.php

@@ -12,14 +12,16 @@
  *
  *<pre>
  * $eventManager = new \Soli\Events\EventManager();
- * // 将针对 "dispatch" 分组的事件监听器，统一整理到 DispatchEvents 类，一并注册
- * $eventManager->on('dispatch', new DispatchEvents);
  *
  * // 注册具体的某个事件监听器
- * $eventManager->on('application:boot', array(new AppEvents, 'boot'));
+ * $eventManager->on('application:boot', function (\Soli\Events\Event $event, $application) {
+ *     echo "应用已启动\n";
+ * });
  *
- * // 触发事件
- * $eventManager->fire('dispatch:beforeDispatchLoop', $this);
+ * // 也可以将针对 "application" 的事件统一整理到 AppEvents 类，一并注册
+ * $eventManager->on('application', new AppEvents);
+ *
+ * // 触发某个具体事件
  * $eventManager->fire('application:boot', $this);
  *</pre>
  */
@@ -39,11 +41,9 @@ class EventManager implements EventManagerInterface
      * 有分号则认为是为具体的某个事件添加监听器
      * 此规则会在 fire 方法中体现
      *
-     * 关于 callable: @see http://cn2.php.net/manual/zh/language.types.callable.php#example-111
-     *
      * @param string $name 事件名称，格式为：「事件分组类型:事件名称」
      *                     可以是事件分组类型，也可以是完整的事件名称
-     * @param object|callable|string $listener 监听器（对象、callable、类名）
+     * @param \Closure|object $listener 监听器（匿名函数、对象实例）
      */
     public function on($name, $listener)
     {

tests/Events/EventManagerTest.php

@@ -8,7 +8,7 @@
 
 class EventManagerTest extends TestCase
 {
-    public function testFire()
+    public function testFireByClosure()
     {
         $eventManager = new EventManager;
         // 监听事件
@@ -19,6 +19,18 @@ function (Event $event, $myComponent) {
             }
         );
 
+        $myComponent = new MyComponent;
+        $myComponent->setEventManager($eventManager);
+
+        $result = $myComponent->someTask();
+
+        $this->assertStringStartsWith('before, do something', $result);
+    }
+
+    public function testFireByInstance()
+    {
+        $eventManager = new EventManager;
+
         $eventManager->on(
             'my-component',
             new MyComponentEvents
@@ -29,7 +41,7 @@ function (Event $event, $myComponent) {
 
         $result = $myComponent->someTask();
 
-        $this->assertStringStartsWith('before, do something', $result);
+        $this->assertStringEndsWith('do something, after', $result);
     }
 }