pub struct Hub<M, R> { /* private fields */ }
Expand description
A subscription hub.
Does the subscription and dispatch.
The exact subscription and routing behaviour is to be implemented by the Registry (of type R
).
The Hub under the hood uses the channel defined in crate::mpsc
module.
Implementations§
source§impl<M, R> Hub<M, R>where
R: Unsubscribe,
impl<M, R> Hub<M, R>where R: Unsubscribe,
sourcepub fn map_registry_for_tests<MapF, Ret>(&self, map: MapF) -> Retwhere
MapF: FnOnce(&R) -> Ret,
pub fn map_registry_for_tests<MapF, Ret>(&self, map: MapF) -> Retwhere MapF: FnOnce(&R) -> Ret,
Provide access to the registry (for test purposes).
source§impl<M, R> Hub<M, R>
impl<M, R> Hub<M, R>
sourcepub fn new(tracing_key: &'static str) -> Selfwhere
R: Default,
pub fn new(tracing_key: &'static str) -> Selfwhere R: Default,
Create a new instance of Hub (with default value for the Registry).
sourcepub fn new_with_registry(tracing_key: &'static str, registry: R) -> Self
pub fn new_with_registry(tracing_key: &'static str, registry: R) -> Self
Create a new instance of Hub over the initialized Registry.
Trait Implementations§
Auto Trait Implementations§
impl<M, R> !RefUnwindSafe for Hub<M, R>
impl<M, R> Send for Hub<M, R>where M: Send, R: Send,
impl<M, R> Sync for Hub<M, R>where M: Send, R: Send,
impl<M, R> Unpin for Hub<M, R>
impl<M, R> !UnwindSafe for Hub<M, R>
Blanket Implementations§
§impl<T> SaturatedConversion for T
impl<T> SaturatedConversion for T
§fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
fn saturated_from<T>(t: T) -> Selfwhere Self: UniqueSaturatedFrom<T>,
§fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
fn saturated_into<T>(self) -> Twhere Self: UniqueSaturatedInto<T>,
Consume self to return an equivalent value of
T
. Read more§impl<T, S> UniqueSaturatedInto<T> for Swhere
T: Bounded,
S: TryInto<T>,
impl<T, S> UniqueSaturatedInto<T> for Swhere T: Bounded, S: TryInto<T>,
§fn unique_saturated_into(self) -> T
fn unique_saturated_into(self) -> T
Consume self to return an equivalent value of
T
.