Struct Intersection

pub struct Intersection<'f> {
    heap: StreamHeap<'f>,
    outs: Vec<IndexedValue>,
    cur_slot: Option<Slot>,
}

A stream of set intersection over multiple fst streams in lexicographic order.

The 'f lifetime parameter refers to the lifetime of the underlying fst.

Fields

heap: StreamHeap<'f>

outs: Vec<IndexedValue>

cur_slot: Option<Slot>

Trait Implementations

impl<'a, 'f> Streamer<'a> for Intersection<'f>

type Item = (&'a [u8], &'a [IndexedValue])

The type of the item emitted by this stream.

fn next(&'a mut self) -> Option<(&'a [u8], &'a [IndexedValue])>

Emits the next element in this stream, or None to indicate the stream has been exhausted.