infinite-stream 0.1.0

Streams (asynchronous iterators) that always keep yielding items (or panic, or become pending forever)
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

use {
    std::marker::PhantomData,
    crate::internal_prelude::*,
};

pub fn pending<T>() -> Pending<T> {
    assert_infinite_stream::<T, _>(Pending { _data: PhantomData })
}

#[must_use = "streams do nothing unless polled"]
pub struct Pending<T> {
    _data: PhantomData<T>,
}

impl<T> Unpin for Pending<T> {}

impl<T> InfiniteStream for Pending<T> {
    type Item = T;

    fn poll_next(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Self::Item> {
        Poll::Pending
    }
}

impl<T> Clone for Pending<T> {
    fn clone(&self) -> Self {
        pending()
    }
}