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(s).

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

where T: ToRedisArgs,

Subscribes to new channel(s) with pattern(s).

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

where T: ToRedisArgs,

Unsubscribes from a channel(s).

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

where T: ToRedisArgs,

Unsubscribes from channel pattern(s).

pub fn ping_message<T>( &mut self, message: impl ToRedisArgs, ) -> Result<T, RedisError>

where T: FromRedisValue,

Sends a ping with a message to the server

pub fn ping<T>(&mut self) -> Result<T, RedisError>

where T: FromRedisValue,

Sends a ping to the server

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 Drop for PubSub<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.