From c2a3465ec0908275c01d5ba0b423e2b4115b6696 Mon Sep 17 00:00:00 2001 From: xzander Date: Thu, 10 Dec 2015 11:52:41 +0500 Subject: [PATCH] Add blankCallback for ping, unsubsribe and punsubcribe methods. --- src/PubSub/Consumer.php | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/src/PubSub/Consumer.php b/src/PubSub/Consumer.php index 7bae990..19e6f81 100644 --- a/src/PubSub/Consumer.php +++ b/src/PubSub/Consumer.php @@ -155,7 +155,7 @@ public function psubscribe(/* channels */) */ public function unsubscribe(/* channels */) { - $this->writeRequest('unsubscribe', func_get_args()); + $this->writeRequest('unsubscribe', func_get_args(), array($this, 'blankCallback')); } /** @@ -165,7 +165,7 @@ public function unsubscribe(/* channels */) */ public function punsubscribe(/* channels */) { - $this->writeRequest('punsubscribe', func_get_args()); + $this->writeRequest('punsubscribe', func_get_args(), array($this, 'blankCallback')); } /** @@ -176,7 +176,7 @@ public function punsubscribe(/* channels */) */ public function ping($payload = null) { - $this->writeRequest('ping', [$payload]); + $this->writeRequest('ping', [$payload], array($this, 'blankCallback')); } /** @@ -202,6 +202,15 @@ public function __invoke($payload, $client, $command) } } + /** + * Blank callback for ping, unsubscribe and punsubscribe methods + * + * @param string $payload Payload returned by the server. + * @param Client $client Associated client instance. + * @param CommandInterface $command Command instance (always NULL in case of streaming contexts). + */ + public function blankCallback($payload, $client, $command) {} + /** * Returns the underlying client instance. *