Struct canadensis::core::subscription::DynamicSubscriptionManager
source · [−]pub struct DynamicSubscriptionManager<S> { /* private fields */ }
Expand description
A subscription manager that dynamically allocates memory
Trait Implementations
sourceimpl<S> Default for DynamicSubscriptionManager<S>
impl<S> Default for DynamicSubscriptionManager<S>
sourcefn default() -> DynamicSubscriptionManager<S>
fn default() -> DynamicSubscriptionManager<S>
Returns the “default value” for a type. Read more
sourceimpl<S> SubscriptionManager<S> for DynamicSubscriptionManager<S>
impl<S> SubscriptionManager<S> for DynamicSubscriptionManager<S>
sourcefn subscribe_message(
&mut self,
subject: SubjectId,
subscription: S
) -> Result<(), OutOfMemoryError>
fn subscribe_message(
&mut self,
subject: SubjectId,
subscription: S
) -> Result<(), OutOfMemoryError>
Stores a message subscription
sourcefn unsubscribe_message(&mut self, subject: SubjectId) -> Option<S>
fn unsubscribe_message(&mut self, subject: SubjectId) -> Option<S>
Removes and returns a message subscription
sourcefn subscribe_request(
&mut self,
service: ServiceId,
subscription: S
) -> Result<(), OutOfMemoryError>
fn subscribe_request(
&mut self,
service: ServiceId,
subscription: S
) -> Result<(), OutOfMemoryError>
Stores a service request subscription
sourcefn unsubscribe_request(&mut self, service: ServiceId) -> Option<S>
fn unsubscribe_request(&mut self, service: ServiceId) -> Option<S>
Removes and returns a service request subscription
sourcefn subscribe_response(
&mut self,
service: ServiceId,
subscription: S
) -> Result<(), OutOfMemoryError>
fn subscribe_response(
&mut self,
service: ServiceId,
subscription: S
) -> Result<(), OutOfMemoryError>
Stores a service response subscription
sourcefn unsubscribe_response(&mut self, service: ServiceId) -> Option<S>
fn unsubscribe_response(&mut self, service: ServiceId) -> Option<S>
Removes and returns a service response subscription
sourcefn find_message_subscription(&self, subject: SubjectId) -> Option<&S>
fn find_message_subscription(&self, subject: SubjectId) -> Option<&S>
Returns a reference to the message subscription matching the provided subject
sourcefn find_message_subscription_mut(
&mut self,
subject: SubjectId
) -> Option<&mut S>
fn find_message_subscription_mut(
&mut self,
subject: SubjectId
) -> Option<&mut S>
Returns a mutable reference to the message subscription matching the provided subject
sourcefn find_request_subscription(&self, service: ServiceId) -> Option<&S>
fn find_request_subscription(&self, service: ServiceId) -> Option<&S>
Returns a reference to the service request subscription matching the provided subject
sourcefn find_request_subscription_mut(
&mut self,
service: ServiceId
) -> Option<&mut S>
fn find_request_subscription_mut(
&mut self,
service: ServiceId
) -> Option<&mut S>
Returns a mutable reference to the service request subscription matching the provided subject
sourcefn find_response_subscription(&self, service: ServiceId) -> Option<&S>
fn find_response_subscription(&self, service: ServiceId) -> Option<&S>
Returns a reference to the service response subscription matching the provided subject
sourcefn find_response_subscription_mut(
&mut self,
service: ServiceId
) -> Option<&mut S>
fn find_response_subscription_mut(
&mut self,
service: ServiceId
) -> Option<&mut S>
Returns a mutable reference to the service response subscription matching the provided subject
sourcefn for_each_message_subscription_mut<F>(&mut self, operation: F) where
F: FnMut(&mut S),
fn for_each_message_subscription_mut<F>(&mut self, operation: F) where
F: FnMut(&mut S),
Executes the provided operation for each message subscription
sourcefn for_each_request_subscription_mut<F>(&mut self, operation: F) where
F: FnMut(&mut S),
fn for_each_request_subscription_mut<F>(&mut self, operation: F) where
F: FnMut(&mut S),
Executes the provided operation for each request subscription
sourcefn for_each_response_subscription_mut<F>(&mut self, operation: F) where
F: FnMut(&mut S),
fn for_each_response_subscription_mut<F>(&mut self, operation: F) where
F: FnMut(&mut S),
Executes the provided operation for each response subscription
Auto Trait Implementations
impl<S> RefUnwindSafe for DynamicSubscriptionManager<S> where
S: RefUnwindSafe,
impl<S> Send for DynamicSubscriptionManager<S> where
S: Send,
impl<S> Sync for DynamicSubscriptionManager<S> where
S: Sync,
impl<S> Unpin for DynamicSubscriptionManager<S> where
S: Unpin,
impl<S> UnwindSafe for DynamicSubscriptionManager<S> where
S: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more