Struct Collector

Source

pub struct Collector<T: Sink> { /* private fields */ }

Expand description

A collector for output lines.

For proper cleanup, call abort() which gracefully waits for the collecting task to complete. It should terminate fast, as an internal termination signal is send to it. If dropped without calling abort(), the termination will be sent as well, but the task will be aborted (forceful, not waiting for completion).

Struct CollectorCopy item path

Implementations§

impl<T: Sink> Collector<T>

pub async fn abort(self) -> Result<T, CollectorError>

Trait Implementations§

impl<T: Sink> Drop for Collector<T>

fn drop(&mut self)

Auto Trait Implementations§

impl<T> Freeze for Collector<T>

impl<T> !RefUnwindSafe for Collector<T>

impl<T> Send for Collector<T>

impl<T> Sync for Collector<T>

impl<T> Unpin for Collector<T>

impl<T> !UnwindSafe for Collector<T>

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct Collector

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,