pub struct MultiplexerBroker { /* private fields */ }
Expand description
Ensures that BatchIterators get access to logs from newly started components.
Implementations§
Source§impl MultiplexerBroker
impl MultiplexerBroker
Sourcepub fn send(&mut self, container: &Arc<LogsArtifactsContainer>)
pub fn send(&mut self, container: &Arc<LogsArtifactsContainer>)
Notify existing BatchIterators of a new logs container so they can include its messages in their results.
Auto Trait Implementations§
impl Freeze for MultiplexerBroker
impl !RefUnwindSafe for MultiplexerBroker
impl Send for MultiplexerBroker
impl Sync for MultiplexerBroker
impl Unpin for MultiplexerBroker
impl !UnwindSafe for MultiplexerBroker
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