pub struct BusConfig<A>where
A: ServiceAddress,{
pub api_type: ZmqSocketType,
pub carrier: Carrier,
pub router: Option<A>,
pub queued: bool,
pub topic: Option<String>,
}Fields§
§api_type: ZmqSocketType§carrier: Carrier§router: Option<A>§queued: boolIndicates whether the messages must be queued, or the send function must fail immediately if the remote point is not available
topic: Option<String>Implementations§
Source§impl<A> BusConfig<A>where
A: ServiceAddress,
impl<A> BusConfig<A>where
A: ServiceAddress,
pub fn with_addr( addr: ServiceAddr, api_type: ZmqSocketType, router: Option<A>, ) -> Self
pub fn with_subscription( addr: ServiceAddr, api_type: ZmqSocketType, topic: Option<String>, ) -> Self
pub fn with_socket( socket: Socket, api_type: ZmqSocketType, router: Option<A>, ) -> Self
Auto Trait Implementations§
impl<A> Freeze for BusConfig<A>where
A: Freeze,
impl<A> RefUnwindSafe for BusConfig<A>where
A: RefUnwindSafe,
impl<A> Send for BusConfig<A>where
A: Send,
impl<A> !Sync for BusConfig<A>
impl<A> Unpin for BusConfig<A>where
A: Unpin,
impl<A> UnwindSafe for BusConfig<A>where
A: 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