add new publishBatch method to PubSubAdapterInterface

README.md

@@ -42,6 +42,13 @@ $adapter->subscribe('my_channel', function ($message) {
 
 // publish messages
 $adapter->publish('my_channel', 'Hello World!');
+
+// publish multiple messages
+$messages = [
+    'message 1',
+    'message 2',
+];
+$adapter->publishBatch('my_channel', $messages);
 ```
 
 ## Writing an Adapter
@@ -66,6 +73,14 @@ public function subscribe($channel, callable $handler);
  * @param mixed $message
  */
 public function publish($channel, $message);
+
+/**
+ * Publish multiple messages to a channel.
+ *
+ * @param string $channel
+ * @param array $messages
+ */
+public function publishBatch($channel, array $messages);
 ```
 
 ## Examples

changelog.md

@@ -2,6 +2,7 @@
 
 ## 2.0.0 - 2017-05-16
 
+* Implement new publishBatch method on PubSubAdapterInterface
 * Change message serialization to only json encode and decode
 
 ## 1.0.0 - 2016-09-02

src/Adapters/DevNullPubSubAdapter.php

@@ -27,4 +27,15 @@ public function publish($channel, $message)
     {
         // your message is going to /dev/null
     }
+
+    /**
+     * Publish multiple messages to a channel.
+     *
+     * @param string $channel
+     * @param array $messages
+     */
+    public function publishBatch($channel, array $messages)
+    {
+        // your messages are going to /dev/null
+    }
 }

src/Adapters/LocalPubSubAdapter.php

@@ -38,6 +38,19 @@ public function publish($channel, $message)
         }
     }
 
+    /**
+     * Publish multiple messages to a channel.
+     *
+     * @param string $channel
+     * @param array $messages
+     */
+    public function publishBatch($channel, array $messages)
+    {
+        foreach ($messages as $message) {
+            $this->publish($channel, $message);
+        }
+    }
+
     /**
      * Return all subscribers on the given channel.
      *

src/PubSubAdapterInterface.php

@@ -19,4 +19,12 @@ public function subscribe($channel, callable $handler);
      * @param mixed $message
      */
     public function publish($channel, $message);
+
+    /**
+     * Publish multiple messages to a channel.
+     *
+     * @param string $channel
+     * @param array $messages
+     */
+    public function publishBatch($channel, array $messages);
 }

tests/LocalPubSubAdapterTest.php

@@ -48,4 +48,33 @@ public function testPublish()
 
         $adapter->publish('test_channel', 'This is a message sent to handler1 & handler2');
     }
+
+    public function testPublishBatch()
+    {
+        $adapter = new LocalPubSubAdapter();
+
+        $handler1 = Mockery::mock(\stdClass::class);
+        $handler1->shouldReceive('handle')
+            ->with('This is a message sent to handler1 & handler2')
+            ->once();
+        $handler1->shouldReceive('handle')
+            ->with('This is another message!')
+            ->once();
+        $adapter->subscribe('test_channel', [$handler1, 'handle']);
+
+        $handler2 = Mockery::mock(\stdClass::class);
+        $handler2->shouldReceive('handle')
+            ->with('This is a message sent to handler1 & handler2')
+            ->once();
+        $handler2->shouldReceive('handle')
+            ->with('This is another message!')
+            ->once();
+        $adapter->subscribe('test_channel', [$handler2, 'handle']);
+
+        $messages = [
+            'This is a message sent to handler1 & handler2',
+            'This is another message!',
+        ];
+        $adapter->publishBatch('test_channel', $messages);
+    }
 }