watermelon-net 0.2.5

Low-level NATS Core network implementation
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

use std::{
    pin::Pin,
    task::{Context, Poll},
};

use futures_core::Stream;

#[derive(Debug, Clone)]
pub(crate) struct IterToStream<I> {
    pub(crate) iter: I,
}

impl<I> Unpin for IterToStream<I> {}

impl<I: Iterator> Stream for IterToStream<I> {
    type Item = I::Item;

    fn poll_next(mut self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<I::Item>> {
        Poll::Ready(self.iter.next())
    }

    fn size_hint(&self) -> (usize, Option<usize>) {
        self.iter.size_hint()
    }
}