photon 0.2.0

Client SDK for Photon
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
27
28
29
30
31
32
33
34
35
36
37
38

use crossbeam_channel::{Receiver, Sender, TrySendError, bounded};

pub(crate) struct Accumulator<P: Copy + Send> {
    tx: Sender<P>,
    points_dropped: u64,
}

impl<P: Copy + Send> Accumulator<P> {
    pub(crate) fn new(channel_capacity: usize) -> (Self, Receiver<P>) {
        let (tx, rx) = bounded(channel_capacity);

        let accumulator = Self {
            tx,
            points_dropped: 0,
        };

        (accumulator, rx)
    }

    pub(crate) fn push(&mut self, point: P) {
        match self.tx.try_send(point) {
            Ok(()) => {}
            Err(TrySendError::Full(point)) => {
                // Block until there's space
                if self.tx.send(point).is_err() {
                    self.points_dropped += 1;
                }
            }
            Err(TrySendError::Disconnected(_)) => {
                self.points_dropped += 1;
            }
        }
    }

    pub(crate) fn points_dropped(&self) -> u64 {
        self.points_dropped
    }
}