Struct DLQ 

pub struct DLQ { /* private fields */ }

Dead Letter Queue for unhandled TPCP envelopes.

Implementations

impl DLQ

pub fn new() -> Self

Creates a DLQ with capacity 100.

pub fn enqueue(&self, env: TPCPEnvelope) -> bool

Enqueues an envelope. Returns false if the queue is full.

pub async fn drain(&self) -> Vec<TPCPEnvelope>

Drains all queued envelopes.

Trait Implementations

impl Default for DLQ

fn default() -> Self

Returns the “default value” for a type.