|
@@ -18,16 +18,16 @@ namespace Predis\PubSub;
|
|
|
*/
|
|
|
abstract class AbstractConsumer implements \Iterator
|
|
|
{
|
|
|
- const SUBSCRIBE = 'subscribe';
|
|
|
- const UNSUBSCRIBE = 'unsubscribe';
|
|
|
- const PSUBSCRIBE = 'psubscribe';
|
|
|
+ const SUBSCRIBE = 'subscribe';
|
|
|
+ const UNSUBSCRIBE = 'unsubscribe';
|
|
|
+ const PSUBSCRIBE = 'psubscribe';
|
|
|
const PUNSUBSCRIBE = 'punsubscribe';
|
|
|
- const MESSAGE = 'message';
|
|
|
- const PMESSAGE = 'pmessage';
|
|
|
- const PONG = 'pong';
|
|
|
+ const MESSAGE = 'message';
|
|
|
+ const PMESSAGE = 'pmessage';
|
|
|
+ const PONG = 'pong';
|
|
|
|
|
|
- const STATUS_VALID = 1; // 0b0001
|
|
|
- const STATUS_SUBSCRIBED = 2; // 0b0010
|
|
|
+ const STATUS_VALID = 1; // 0b0001
|
|
|
+ const STATUS_SUBSCRIBED = 2; // 0b0010
|
|
|
const STATUS_PSUBSCRIBED = 4; // 0b0100
|
|
|
|
|
|
private $position = null;
|