Struct CallbackDrain 

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

Drains completions and invokes a caller-provided callback for each one.

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

let ring = Ring::new(RingConfig::default())?;
let drain = CallbackDrain::new(ring, 4);
let _processed = drain.drain(None, |event| {
    let _ = event.id();
})?;

Implementations

impl<F: BackendFactory> CallbackDrain<F>

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

Creates a callback-driven drain adapter.

pub fn drain<C>(&self, timeout: Option<Duration>, callback: C) -> Result<usize>

where C: FnMut(CompletionEvent),

Drains up to limit completions, invoking callback for each one.

Trait Implementations

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.