Struct BlockingDrain 

pub struct BlockingDrain<F: BackendFactory> { /* private fields */ }

Waits for completions using a blocking call.

use wireshift::{Ring, RingConfig, strategy::BlockingDrain};

let ring = Ring::new(RingConfig::default())?;
let drain = BlockingDrain::new(ring);
let _ = drain.wait(None);

Implementations

impl<F: BackendFactory> BlockingDrain<F>

pub fn new(ring: Ring<F>) -> Self

Creates a blocking completion adapter.

pub fn wait(&self, timeout: Option<Duration>) -> Result<CompletionEvent>

Waits for exactly one completion.

Trait Implementations

impl<F: Clone + BackendFactory> Clone for BlockingDrain<F>

fn clone(&self) -> BlockingDrain<F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.