Struct memorix_client_redis::MemorixPubSubItem

pub struct MemorixPubSubItem<K, P>
where
    P: DeserializeOwned,
{ /* private fields */ }

Implementations

impl<K, P> MemorixPubSubItem<K, P>

where K: Serialize, P: DeserializeOwned + Serialize,

pub fn new(memorix_base: MemorixBase, id: String) -> Self

pub fn key(&self, key: &K) -> Result<String, Box<dyn Error + Sync + Send>>

pub async fn subscribe( &self, key: &K, ) -> Result<Pin<Box<dyn Stream<Item = Result<MemorixPayload<P>, Box<dyn Error + Sync + Send>>> + Send>>, Box<dyn Error + Sync + Send>>

pub async fn publish( &mut self, key: &K, payload: &P, ) -> Result<(), Box<dyn Error + Sync + Send>>

Trait Implementations

impl<K: Clone, P> Clone for MemorixPubSubItem<K, P>

where P: DeserializeOwned + Clone,

fn clone(&self) -> MemorixPubSubItem<K, P>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.