[−][src]Struct ripb::Bus
An in process bus.
You can create a bus with the [new
] method, then create new Subscriber
s with the
[create_subscriber
] method, and push some messages on the bus with the [publish
] method.
If you need to send messages from multiple threads, [clone
] the bus and use one instance per
thread
Methods
impl Bus
[src]
pub fn new() -> Self
[src]
Create a new bus, with a thread count equal to the number of CPUs
pub fn with_thread_count(thread_count: NonZeroUsize) -> Self
[src]
Create a new bus with the given thread count
pub fn create_subscriber(&self) -> Subscriber
[src]
Create a new subscriber for this bus
pub fn publish<M: Message + 'static>(&self, message: M)
[src]
Publish a new message on this bus
Trait Implementations
Auto Trait Implementations
impl Send for Bus
impl Sync for Bus
impl Unpin for Bus
impl UnwindSafe for Bus
impl RefUnwindSafe for Bus
Blanket Implementations
impl<T> Message for T where
T: Send + Sync,
[src]
T: Send + Sync,
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,