Struct Writer 

pub struct Writer<D>
where
    D: CpuSample,
{ /* private fields */ }

Circular writer

Trait Implementations

impl<D> BufferWriter for Writer<D>

where D: CpuSample,

type Reader = Reader<D>

The corresponding local reader.

fn init(&mut self, block_id: BlockId, port_id: PortId, inbox: BlockInbox)

Initialize the writer with its owning block, port id, and inbox.

fn validate(&self) -> Result<(), Error>

Validate that this writer is connected and ready to run.

fn connect(&mut self, dest: &mut Self::Reader)

Connect the writer to a matching reader.

async fn notify_finished(&mut self)

Notify downstream blocks that we are done.

fn block_id(&self) -> BlockId

Get the owning block id.

fn port_id(&self) -> PortId

Get the owning port id.

fn connect_dyn(&mut self, dest: &mut dyn BufferReader) -> Result<(), Error>

Connect the writer to a type-erased local reader.

impl<D> CpuBufferWriter for Writer<D>

where D: CpuSample,

type Item = D

Item type.

fn slice(&mut self) -> &mut [Self::Item]

Get writable slice.

fn produce(&mut self, items: usize)

Mark n items as produced.

fn slice_with_tags(&mut self) -> (&mut [Self::Item], Tags<'_>)

Get writable slice and tag sink.

fn set_min_items(&mut self, n: usize)

Set minimum number of writable items.

fn set_min_buffer_size_in_items(&mut self, n: usize)

Set minimum buffer size.

fn max_items(&self) -> usize

Maximum writable items.

impl<D> Debug for Writer<D>

where D: CpuSample,

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

Formats the value using the given formatter.

impl<D> Default for Writer<D>

where D: CpuSample,

fn default() -> Self

Returns the “default value” for a type.