pixelbomber 1.2.4

Insanely fast pixelflut client for images and animations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::sync::{
    mpsc::{Receiver, SyncSender, TrySendError},
    Arc,
};

use crate::image_handler::Command;

pub fn get_merger(
    source: Receiver<(Arc<Command>, usize)>,
    sink: SyncSender<Arc<Command>>,
) -> impl FnMut() {
    move || {
        let mut last_idx = 0;
        while let Ok((commands, index)) = source.recv() {
            if index > last_idx {
                last_idx = index;
                if let Err(TrySendError::Disconnected(_)) = sink.try_send(commands) {
                    break;
                }
            }
        }
    }
}