Add DispatcherInterface::unregisterAllHandlers + implementation

src/Dispatcher.php

@@ -260,6 +260,15 @@ public function registerHandlers(string $type, array $handlers): DispatcherInter
         return $this;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function unregisterAllHandlers(): DispatcherInterface
+    {
+        $this->handlers = [];
+        return $this;
+    }
+
     /**
      * Serialize message to logger context
      *

src/DispatcherInterface.php

@@ -30,6 +30,13 @@ public function registerHandler(string $type, HandlerInterface $handler): Dispat
      */
     public function registerHandlers(string $type, array $handler): DispatcherInterface;
 
+    /**
+     * Will unregister all handlers. This method is useful for testing.
+     *
+     * @return DispatcherInterface
+     */
+    public function unregisterAllHandlers(): DispatcherInterface;
+
     /**
      * Basic method for background job to star listening.
      *

tests/HandleTest.php

@@ -164,4 +164,24 @@ public function testMaxItemProcess(): void
         $this->assertEquals(['n' => 2], $receivedMessages[0]->getPayload());
         $this->assertEquals(['n' => 1], $receivedMessages[1]->getPayload());
     }
+
+    public function testUnregisterAllHandlers(): void
+    {
+        $message1 = new Message('event1', ['a' => 'b']);
+        $message2 = new Message('event2', ['c' => 'd']);
+
+        $driver = new DummyDriver([$message1, $message2]);
+        $dispatcher = new Dispatcher($driver);
+
+        $handler = new TestHandler();
+
+        $dispatcher->registerHandler('event2', $handler);
+        $dispatcher->handle();
+
+        $dispatcher->unregisterAllHandlers();
+        $dispatcher->handle();
+
+        $receivedMessages = $handler->getReceivedMessages();
+        $this->assertCount(1, $receivedMessages);
+    }
 }