Struct BatchDrain 

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

Drains up to limit completions in one call.

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

let ring = Ring::new(RingConfig::default())?;
let drain = BatchDrain::new(ring, 16);
let _ = drain;

Implementations

impl<F: BackendFactory> BatchDrain<F>

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

Creates a batch drain adapter.

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

Attempts to drain up to limit completions within the optional timeout budget.

Trait Implementations

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.