mirror of
https://github.com/predis/predis.git
synced 2026-08-30 20:21:31 +00:00
Parse WATCH and UNWATCH replies as boolean values.
This commit is contained in:
+12
-10
@@ -2720,6 +2720,18 @@ class Discard extends \Predis\MultiBulkCommand {
|
||||
public function getCommandId() { return 'DISCARD'; }
|
||||
}
|
||||
|
||||
class Watch extends \Predis\MultiBulkCommand {
|
||||
public function canBeHashed() { return false; }
|
||||
public function getCommandId() { return 'WATCH'; }
|
||||
public function parseResponse($data) { return (bool) $data; }
|
||||
}
|
||||
|
||||
class Unwatch extends \Predis\MultiBulkCommand {
|
||||
public function canBeHashed() { return false; }
|
||||
public function getCommandId() { return 'UNWATCH'; }
|
||||
public function parseResponse($data) { return (bool) $data; }
|
||||
}
|
||||
|
||||
/* publish/subscribe */
|
||||
class Subscribe extends \Predis\MultiBulkCommand {
|
||||
public function canBeHashed() { return false; }
|
||||
@@ -2746,16 +2758,6 @@ class Publish extends \Predis\MultiBulkCommand {
|
||||
public function getCommandId() { return 'PUBLISH'; }
|
||||
}
|
||||
|
||||
class Watch extends \Predis\MultiBulkCommand {
|
||||
public function canBeHashed() { return false; }
|
||||
public function getCommandId() { return 'WATCH'; }
|
||||
}
|
||||
|
||||
class Unwatch extends \Predis\MultiBulkCommand {
|
||||
public function canBeHashed() { return false; }
|
||||
public function getCommandId() { return 'UNWATCH'; }
|
||||
}
|
||||
|
||||
/* persistence control commands */
|
||||
class Save extends \Predis\MultiBulkCommand {
|
||||
public function canBeHashed() { return false; }
|
||||
|
||||
Reference in New Issue
Block a user