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. *