Struct StreamHeap

struct StreamHeap<'f> {
    rdrs: Vec<Box<dyn for<'a> Streamer<'a, Item = (&'a [u8], Output)> + 'f>>,
    heap: BinaryHeap<Slot>,
}

Fields

rdrs: Vec<Box<dyn for<'a> Streamer<'a, Item = (&'a [u8], Output)> + 'f>>

heap: BinaryHeap<Slot>

Implementations

impl<'f> StreamHeap<'f>

fn new( streams: Vec<Box<dyn for<'a> Streamer<'a, Item = (&'a [u8], Output)> + 'f>>, ) -> StreamHeap<'f>

fn pop(&mut self) -> Option<Slot>

fn peek_is_duplicate(&self, key: &[u8]) -> bool

fn pop_if_equal(&mut self, key: &[u8]) -> Option<Slot>

fn pop_if_le(&mut self, key: &[u8]) -> Option<Slot>

fn num_slots(&self) -> usize

fn refill(&mut self, slot: Slot)