Add DispatcherInterface::unregisterHandler + implementation

src/Dispatcher.php

@@ -269,6 +269,22 @@ public function unregisterAllHandlers(): DispatcherInterface
         return $this;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function unregisterHandler(string $type, HandlerInterface $handler): DispatcherInterface
+    {
+        if (!isset($this->handlers[$type])) {
+            return $this;
+        }
+        $this->handlers[$type] = array_filter(
+            $this->handlers[$type],
+            fn ($registeredHandler) => $registeredHandler !== $handler
+        );
+
+        return $this;
+    }
+
     /**
      * Serialize message to logger context
      *

src/DispatcherInterface.php

@@ -37,6 +37,16 @@ public function registerHandlers(string $type, array $handler): DispatcherInterf
      */
     public function unregisterAllHandlers(): DispatcherInterface;
 
+    /**
+     * Will unregister a specific handler.
+     *
+     * @param string $type
+     * @param HandlerInterface $handler
+     *
+     * @return DispatcherInterface
+     */
+    public function unregisterHandler(string $type, HandlerInterface $handler): DispatcherInterface;
+
     /**
      * Basic method for background job to star listening.
      *

tests/HandleTest.php

@@ -184,4 +184,29 @@ public function testUnregisterAllHandlers(): void
         $receivedMessages = $handler->getReceivedMessages();
         $this->assertCount(1, $receivedMessages);
     }
+
+    public function testUnregisterHandler(): void
+    {
+        $message1 = new Message('event1', ['a' => 'b']);
+        $message2 = new Message('event2', ['c' => 'd']);
+
+        $driver = new DummyDriver([$message1, $message2]);
+        $dispatcher = new Dispatcher($driver);
+
+        $firstHandler = new TestHandler();
+        $secondHandler = new TestHandler();
+
+        $dispatcher->registerHandler('event1', $firstHandler);
+        $dispatcher->registerHandler('event2', $secondHandler);
+        $dispatcher->handle();
+
+        $dispatcher->unregisterHandler('event2', $secondHandler);
+        $dispatcher->handle();
+
+        $firstHandlerReceivedMessages = $firstHandler->getReceivedMessages();
+        $this->assertCount(2, $firstHandlerReceivedMessages);
+
+        $secondHandlerReceivedMessages = $secondHandler->getReceivedMessages();
+        $this->assertCount(1, $secondHandlerReceivedMessages);
+    }
 }