Struct Queue 

pub struct Queue<Q, O>
where
    Q: Queue<Packet>,
    O: Write,
{ /* private fields */ }

Implementations

impl<Q, O> PcapQueue<Q, O>

where Q: Queue<Packet>, O: Write,

pub fn new(queue: Q, out: Writer<O>, direction: Direction) -> Self

Trait Implementations

impl<Q, O> Queue<Packet> for PcapQueue<Q, O>

where Q: Queue<Packet>, O: Write,

fn push_lazy( &mut self, value: &mut dyn Pushable<Packet>, ) -> Result<Option<Packet>, PushError>

fn push_with_notify( &mut self, value: &mut dyn Pushable<Packet>, cx: &mut Context<'_>, ) -> Result<Option<Packet>, PushError>

fn pop(&mut self) -> Result<Packet, PopError>

fn pop_with_notify(&mut self, cx: &mut Context<'_>) -> Result<Packet, PopError>

fn close(&mut self) -> Result<(), CloseError>

fn is_closed(&self) -> bool

fn is_empty(&self) -> bool

fn is_full(&self) -> bool

fn len(&self) -> usize

fn capacity(&self) -> Option<usize>

fn push(&mut self, value: T) -> Result<Option<T>, (PushError, T)>

Pushes value into the queue while returning it as an error if the operation fails

fn check_push(&self) -> Result<(), PushError>