Struct PubSub

pub struct PubSub<'a> { /* private fields */ }

Represents a pubsub connection.

Implementations

impl<'a> PubSub<'a>

The pubsub object provides convenient access to the redis pubsub system. Once created you can subscribe and unsubscribe from channels and listen in on messages.

Example:

let client = redis::Client::open("redis://127.0.0.1/")?;
let mut con = client.get_connection()?;
let mut pubsub = con.as_pubsub();
pubsub.subscribe("channel_1")?;
pubsub.subscribe("channel_2")?;

loop {
    let msg = pubsub.get_message()?;
    let payload : String = msg.get_payload()?;
    println!("channel '{}': {}", msg.get_channel_name(), payload);
}

pub fn subscribe<T>(&mut self, channel: T) -> Result<(), RedisError>

where T: ToRedisArgs,

Subscribes to a new channel.

pub fn psubscribe<T>(&mut self, pchannel: T) -> Result<(), RedisError>

where T: ToRedisArgs,

Subscribes to a new channel with a pattern.

pub fn unsubscribe<T>(&mut self, channel: T) -> Result<(), RedisError>

where T: ToRedisArgs,

Unsubscribes from a channel.

pub fn punsubscribe<T>(&mut self, pchannel: T) -> Result<(), RedisError>

where T: ToRedisArgs,

Unsubscribes from a channel with a pattern.

pub fn get_message(&mut self) -> Result<Msg, RedisError>

Fetches the next message from the pubsub connection. Blocks until a message becomes available. This currently does not provide a wait not to block :(

The message itself is still generic and can be converted into an appropriate type through the helper methods on it.

pub fn set_read_timeout(&self, dur: Option<Duration>) -> Result<(), RedisError>

Sets the read timeout for the connection.

If the provided value is None, then get_message call will block indefinitely. It is an error to pass the zero Duration to this method.

Trait Implementations

impl<'a> Drop for PubSub<'a>

fn drop(&mut self)

Executes the destructor for this type.