Struct archivist_lib::logs::multiplex::MultiplexerHandle
source · pub struct MultiplexerHandle<I> {
pub trace_id: Id,
/* private fields */
}
Expand description
A handle to a running multiplexer. Can be used to add new sub-streams to the multiplexer.
Fields§
§trace_id: Id
Implementations§
source§impl<I> MultiplexerHandle<I>
impl<I> MultiplexerHandle<I>
sourcepub fn send(
&self,
identity: Arc<ComponentIdentity>,
stream: PinStream<I>
) -> bool
pub fn send( &self, identity: Arc<ComponentIdentity>, stream: PinStream<I> ) -> bool
Send a new substream to the multiplexer. Returns true
if it is still listening.
pub fn multiplexer_id(&self) -> usize
pub fn parent_trace_id(&self) -> Id
Auto Trait Implementations§
impl<I> Freeze for MultiplexerHandle<I>
impl<I> !RefUnwindSafe for MultiplexerHandle<I>
impl<I> Send for MultiplexerHandle<I>
impl<I> Sync for MultiplexerHandle<I>
impl<I> Unpin for MultiplexerHandle<I>
impl<I> !UnwindSafe for MultiplexerHandle<I>
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