postgres 0.17.0-alpha.1

A native, synchronous PostgreSQL client
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 futures::Stream;
use std::io;
use std::io::Read;
use std::pin::Pin;
use std::task::{Context, Poll};

pub struct CopyInStream<R>(pub R);

impl<R> Stream for CopyInStream<R>
where
    R: Read + Unpin,
{
    type Item = io::Result<Vec<u8>>;

    fn poll_next(
        mut self: Pin<&mut Self>,
        _: &mut Context<'_>,
    ) -> Poll<Option<io::Result<Vec<u8>>>> {
        let mut buf = vec![];
        match self.0.by_ref().take(4096).read_to_end(&mut buf)? {
            0 => Poll::Ready(None),
            _ => Poll::Ready(Some(Ok(buf))),
        }
    }
}