PubSubSplitSink

rustis::client

Struct PubSubSplitSink 

Source 
pub struct PubSubSplitSink { /* private fields */ }
Expand description

A pub sub Sink part of the split pair. It allows to subscribe/unsubscribe to/from channels or patterns

Implementations§

Source§

impl PubSubSplitSink

Source

pub async fn subscribe<C, CC>(&mut self, channels: CC) -> Result<()>
where C: SingleArg + Send, CC: SingleArgCollection<C>,

Subscribe to additional channels

Source

pub async fn psubscribe<P, PP>(&mut self, patterns: PP) -> Result<()>
where P: SingleArg + Send, PP: SingleArgCollection<P>,

Subscribe to additional patterns

Source

pub async fn ssubscribe<C, CC>(&mut self, shardchannels: CC) -> Result<()>
where C: SingleArg + Send, CC: SingleArgCollection<C>,

Subscribe to additional shardchannels

Source

pub async fn unsubscribe<C, CC>(&mut self, channels: CC) -> Result<()>
where C: SingleArg + Send, CC: SingleArgCollection<C>,

Unsubscribe from the given channels

Source

pub async fn punsubscribe<C, CC>(&mut self, patterns: CC) -> Result<()>
where C: SingleArg + Send, CC: SingleArgCollection<C>,

Unsubscribe from the given patterns

Source

pub async fn sunsubscribe<C, CC>(&mut self, shardchannels: CC) -> Result<()>
where C: SingleArg + Send, CC: SingleArgCollection<C>,

Unsubscribe from the given patterns

Source

pub async fn close(self) -> Result<()>

Close the stream by cancelling all subscriptions Calling close allows to wait for all the unsubscriptions. drop will achieve the same process but silently in background

Trait Implementations§

Source§

impl Drop for PubSubSplitSink

Source§

fn drop(&mut self)

Cancel all subscriptions before dropping

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V