[−][src]Struct redis::aio::PubSub
aio
only.Represents a PubSub
connection.
Implementations
impl<C> PubSub<C> where
C: Unpin + AsyncRead + AsyncWrite + Send,
[src]
C: Unpin + AsyncRead + AsyncWrite + Send,
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(self) -> Connection<C>
[src]
Exits from PubSub
mode and converts PubSub
into Connection
.
Auto Trait Implementations
impl<C = Pin<Box<dyn AsyncStream + 'static + Send + Sync, Global>>> !RefUnwindSafe for PubSub<C>
impl<C> Send for PubSub<C> where
C: Send,
C: Send,
impl<C> Sync for PubSub<C> where
C: Sync,
C: Sync,
impl<C> Unpin for PubSub<C> where
C: Unpin,
C: Unpin,
impl<C = Pin<Box<dyn AsyncStream + 'static + Send + Sync, Global>>> !UnwindSafe for PubSub<C>
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,
pub 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.
pub 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.
pub 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>,