Struct Emitter

Source

pub struct Emitter<'a, OutF: RecFamily> { /* private fields */ }

Expand description

Stack-borrowed emitter handed to flat_map closures. Parameterized by the output family (a 'static tag), so user closures never name the concrete downstream stack type or the buffer lifetime. Each emit is one virtual call, confined to flat_map stages.

Emitter

Struct Emitter Copy item path

Implementations§

impl<OutF: RecFamily> Emitter<'_, OutF>

pub fn emit<'buf>(&mut self, payload: OutF::Rec<'buf>) -> Flow

pub fn meta(&self) -> RecordMeta

Trait Implementations§

impl<OutF: RecFamily> Debug for Emitter<'_, OutF>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Auto Trait Implementations§

impl<'a, OutF> !RefUnwindSafe for Emitter<'a, OutF>

impl<'a, OutF> !Send for Emitter<'a, OutF>

impl<'a, OutF> !Sync for Emitter<'a, OutF>

impl<'a, OutF> !UnwindSafe for Emitter<'a, OutF>

impl<'a, OutF> Freeze for Emitter<'a, OutF>where &'a mut dyn CollectorFor<OutF>: Freeze,

impl<'a, OutF> Unpin for Emitter<'a, OutF>where &'a mut dyn CollectorFor<OutF>: Unpin,

impl<'a, OutF> UnsafeUnpin for Emitter<'a, OutF>where &'a mut dyn CollectorFor<OutF>: UnsafeUnpin,

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

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> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

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<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

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 Emitter

impl<'a, OutF> Freeze for Emitter<'a, OutF>
where &'a mut dyn CollectorFor<OutF>: Freeze,

impl<'a, OutF> Unpin for Emitter<'a, OutF>
where &'a mut dyn CollectorFor<OutF>: Unpin,

impl<'a, OutF> UnsafeUnpin for Emitter<'a, OutF>
where &'a mut dyn CollectorFor<OutF>: UnsafeUnpin,

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

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

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

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

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

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

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