mirror of
https://github.com/predis/predis.git
synced 2026-09-04 23:08:00 +00:00
Make it possible to use any kind of callable for PUB/SUB callbacks.
This commit is contained in:
@@ -377,7 +377,7 @@ class Client
|
||||
}
|
||||
|
||||
foreach ($pubsub as $message) {
|
||||
if ($callable($pubsub, $message) === false) {
|
||||
if (call_user_func($callable, $pubsub, $message) === false) {
|
||||
$pubsub->closeContext();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -124,18 +124,18 @@ class DispatcherLoop
|
||||
if ($kind !== PubSubContext::MESSAGE && $kind !== PubSubContext::PMESSAGE) {
|
||||
if (isset($this->subscriptionCallback)) {
|
||||
$callback = $this->subscriptionCallback;
|
||||
$callback($message);
|
||||
call_user_func($callback, $message);
|
||||
}
|
||||
continue;
|
||||
}
|
||||
|
||||
if (isset($this->callbacks[$message->channel])) {
|
||||
$callback = $this->callbacks[$message->channel];
|
||||
$callback($message->payload);
|
||||
call_user_func($callback, $message->payload);
|
||||
}
|
||||
else if (isset($this->defaultCallback)) {
|
||||
$callback = $this->defaultCallback;
|
||||
$callback($message);
|
||||
call_user_func($callback, $message);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user