deluge 0.2.1

A highly concurrent stream library driving the underlying futures either concurrently or in parallel to process streaming operations as quickly as possible.
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

use crate::deluge::Deluge;

pub struct Last<Del> {
    deluge: Del,
}

impl<Del> Last<Del> {
    pub(crate) fn new(deluge: Del) -> Self {
        Self { deluge }
    }
}

impl<Del> Deluge for Last<Del>
where
    Del: Deluge,
{
    type Item = Del::Item;
    type Output<'a> = Del::Output<'a> where Self: 'a;

    fn next(&self) -> Option<Self::Output<'_>> {
        let mut previous_value = None;
        while let Some(v) = self.deluge.next() {
            previous_value = Some(v);
        }

        previous_value
    }
}