Subscriber

class Subscriber {

this(string host = "127.0.0.1", ushort port = 6379);

this(TcpSocket conn);

size_t subscribe(string channel, Callback callback);

size_t psubscribe(string pattern, PCallback callback);

size_t unsubscribe(string channel);

size_t unsubscribe();

size_t punsubscribe(string pattern);

size_t punsubscribe();

Response quit();

Response ping(string argument = null);

void processMessages();

}

Constructors

this this(string host = "127.0.0.1", ushort port = 6379): Create a new non-blocking subscriber using a Redis host and port
this this(TcpSocket conn): Create a new subscriber using an existing socket

Members

Functions

ping Response ping(string argument = null): Send a PING command
processMessages void processMessages(): Poll for queued messages on the redis server and call their callbacks
psubscribe size_t psubscribe(string pattern, PCallback callback): Subscribe to a channel pattern
punsubscribe size_t punsubscribe(string pattern): Unsubscribe from a channel pattern
punsubscribe size_t punsubscribe(): Unsubscribe from all channel patterns
quit Response quit(): Close the redis connection
subscribe size_t subscribe(string channel, Callback callback): Subscribe to a channel
unsubscribe size_t unsubscribe(string channel): Unsubscribe from a channel
unsubscribe size_t unsubscribe(): Unsubscribe from all channels

Meta

Source

See Implementation

redis subscriber classes

Subscriber

functions

isType