pub struct BrokerHandle {
pub state: Arc<BrokerState>,
pub url: String,
/* private fields */
}Expand description
Handle to a running broker, including the optional flush thread.
When dropped, signals the flush thread to stop and joins it, then shuts down the tokio runtime. If the handle is in “reattached” mode (connected to an existing broker), dropping it is a no-op.
Fields§
§state: Arc<BrokerState>Shared broker state.
url: StringThe URL the broker is listening on.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for BrokerHandle
impl !RefUnwindSafe for BrokerHandle
impl Send for BrokerHandle
impl Sync for BrokerHandle
impl Unpin for BrokerHandle
impl UnsafeUnpin for BrokerHandle
impl !UnwindSafe for BrokerHandle
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more