Struct InMemorySink 

pub struct InMemorySink { /* private fields */ }

Test sink: collects envelopes into a bounded ring buffer.

Implementations

impl InMemorySink

pub fn new() -> InMemorySink

Create a sink with the default capacity (1024).

pub fn with_capacity(capacity: usize) -> InMemorySink

Create a sink with a specific ring buffer capacity.

pub fn handle(&self) -> InMemoryHandle

Stable handle for drain() / wait_for() / count(). Cheap to clone — internally one Arc ref-count bump.

Trait Implementations

impl Clone for InMemorySink

fn clone(&self) -> InMemorySink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InMemorySink

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

Formats the value using the given formatter.

impl Default for InMemorySink

fn default() -> InMemorySink

Returns the “default value” for a type.

impl Sink for InMemorySink

fn deliver(&self, env: ScrubbedEnvelope<'_>)

Hand the envelope to the sink. Must not block; long IO is queued internally. Spec 11 § 4 / spec 14 § 5.

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Flush in-flight batches; awaits IO if needed.

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Shut down (drain + close). Idempotent.