pub enum TopicMessage<P, Route> {
Subscribe(Route),
Unsubscribe(Route),
Publish(P),
}Expand description
Commands accepted by a Topic.
Variants§
Subscribe(Route)
Add a subscriber if absent.
Unsubscribe(Route)
Remove a subscriber if present.
Publish(P)
Publish one owned value to the current membership snapshot.
Auto Trait Implementations§
impl<P, Route> Freeze for TopicMessage<P, Route>
impl<P, Route> RefUnwindSafe for TopicMessage<P, Route>where
Route: RefUnwindSafe,
P: RefUnwindSafe,
impl<P, Route> Send for TopicMessage<P, Route>
impl<P, Route> Sync for TopicMessage<P, Route>
impl<P, Route> Unpin for TopicMessage<P, Route>
impl<P, Route> UnsafeUnpin for TopicMessage<P, Route>where
Route: UnsafeUnpin,
P: UnsafeUnpin,
impl<P, Route> UnwindSafe for TopicMessage<P, Route>where
Route: UnwindSafe,
P: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more