Struct CacheSession

pub struct CacheSession<'session, M: FnMut(InboundMessage) + Send + 'session, E: FnMut(SessionEvent) + Send + 'session> { /* private fields */ }

Implementations

impl<'session, M: FnMut(InboundMessage) + Send, E: FnMut(SessionEvent) + Send> CacheSession<'session, M, E>

pub fn blocking_cache_request<T>( &self, topic: T, request_id: u64, subscribe: bool, ) -> Result<(), SessionError>

where T: Into<Vec<u8>>,

Methods from Deref<Target = Session<'session, M, E>>

pub fn publish(&self, message: OutboundMessage) -> Result<(), SessionError>

pub fn subscribe<T>(&self, topic: T) -> Result<(), SessionError>

where T: Into<Vec<u8>>,

pub fn unsubscribe<T>(&self, topic: T) -> Result<(), SessionError>

where T: Into<Vec<u8>>,

pub fn request( &self, message: OutboundMessage, timeout_ms: NonZeroU32, ) -> Result<InboundMessage, SessionError>

Trait Implementations

impl<'session, M: FnMut(InboundMessage) + Send, E: FnMut(SessionEvent) + Send> Deref for CacheSession<'session, M, E>

type Target = Session<'session, M, E>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<M: FnMut(InboundMessage) + Send, E: FnMut(SessionEvent) + Send> DerefMut for CacheSession<'_, M, E>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<M: FnMut(InboundMessage) + Send, E: FnMut(SessionEvent) + Send> Drop for CacheSession<'_, M, E>

fn drop(&mut self)

Executes the destructor for this type.

impl<M: FnMut(InboundMessage) + Send, E: FnMut(SessionEvent) + Send> Send for CacheSession<'_, M, E>

impl<M: FnMut(InboundMessage) + Send, E: FnMut(SessionEvent) + Send> Sync for CacheSession<'_, M, E>