rc_event_queue 0.4.3

VecDeque-like fast, unbounded, FIFO, concurent read-lock-free message queue.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use crate::event_reader::LendingIterator;

pub fn consume_copies<T: Clone>(iter: &mut impl LendingIterator<ItemValue = T>) -> Vec<T> {
    consume_mapped(iter, |item| item.clone())
}

pub fn consume_mapped<T, F, R>(iter: &mut impl LendingIterator<ItemValue = T>, f: F) -> Vec<R>
where F: Fn(&T) -> R
{
    let mut v = Vec::new();
    while let Some(item) = iter.next(){
        v.push( f(item) );
    }
    v
}

pub fn skip<T>(iter: &mut impl LendingIterator<ItemValue = T>, len : usize) {
    let mut i = 0;
    while let Some(_) = iter.next(){
        i+=1;

        if i == len {
            break;
        }
    }
}