Struct trezm_redis::aio::PubSub

pub struct PubSub(_);

Represents a PubSub connection.

Methods

impl PubSub

pub async fn subscribe<'_, T: ToRedisArgs>(
    &'_ mut self,
    channel: T
) -> RedisResult<()>

Subscribes to a new channel.

pub async fn psubscribe<'_, T: ToRedisArgs>(
    &'_ mut self,
    pchannel: T
) -> RedisResult<()>

Subscribes to a new channel with a pattern.

pub async fn unsubscribe<'_, T: ToRedisArgs>(
    &'_ mut self,
    channel: T
) -> RedisResult<()>

Unsubscribes from a channel.

pub async fn punsubscribe<'_, T: ToRedisArgs>(
    &'_ mut self,
    pchannel: T
) -> RedisResult<()>

Unsubscribes from a channel with a pattern.

pub fn on_message<'a>(&'a mut self) -> impl Stream<Item = Msg> + 'a

Returns Stream of Msgs from this PubSubs subscriptions.

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

pub async fn into_connection(__arg0: Self) -> Connection

Exits from PubSub mode and converts PubSub into Connection.