[−][src]Struct redis::aio::PubSub
Represents a PubSub
connection.
Implementations
impl PubSub
[src]
pub async fn subscribe<T: ToRedisArgs, '_>(
&'_ mut self,
channel: T
) -> RedisResult<()>
[src]
&'_ mut self,
channel: T
) -> RedisResult<()>
Subscribes to a new channel.
pub async fn psubscribe<T: ToRedisArgs, '_>(
&'_ mut self,
pchannel: T
) -> RedisResult<()>
[src]
&'_ mut self,
pchannel: T
) -> RedisResult<()>
Subscribes to a new channel with a pattern.
pub async fn unsubscribe<T: ToRedisArgs, '_>(
&'_ mut self,
channel: T
) -> RedisResult<()>
[src]
&'_ mut self,
channel: T
) -> RedisResult<()>
Unsubscribes from a channel.
pub async fn punsubscribe<T: ToRedisArgs, '_>(
&'_ mut self,
pchannel: T
) -> RedisResult<()>
[src]
&'_ 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
[src]
Returns Stream
of Msg
s from this PubSub
s subscriptions.
The message itself is still generic and can be converted into an appropriate type through the helper methods on it.
pub fn into_on_message(self) -> impl Stream<Item = Msg>
[src]
Returns Stream
of Msg
s from this PubSub
s subscriptions consuming it.
The message itself is still generic and can be converted into an appropriate type through the helper methods on it. This can be useful in cases where the stream needs to be returned or held by something other
pub async fn into_connection(__arg0: Self) -> Connection
[src]
Exits from PubSub
mode and converts PubSub
into Connection
.
Auto Trait Implementations
impl !RefUnwindSafe for PubSub
impl Send for PubSub
impl Sync for PubSub
impl Unpin for PubSub
impl !UnwindSafe for PubSub
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,