pub struct TraceTransport;Implementations§
Source§impl TraceTransport
impl TraceTransport
Sourcepub async fn accept_loop(config: TraceTransportConfig, emitter: TraceEmitter)
pub async fn accept_loop(config: TraceTransportConfig, emitter: TraceEmitter)
Start accepting out-of-process subscriber connections and forwarding events as newline-delimited JSON.
This future runs forever (until the process exits or the socket
errors fatally). Spawn it with tokio::spawn.
§Subscriber cap
At most MAX_SUBSCRIBERS connections are served simultaneously.
Connection #MAX_SUBSCRIBERS + 1 receives a JSON error line and
is closed.
Auto Trait Implementations§
impl Freeze for TraceTransport
impl RefUnwindSafe for TraceTransport
impl Send for TraceTransport
impl Sync for TraceTransport
impl Unpin for TraceTransport
impl UnsafeUnpin for TraceTransport
impl UnwindSafe for TraceTransport
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