jason 0.2.0

JSON-RPC 2.0 client library
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
39

use std::pin::Pin;

use async_stream::stream;
use futures::Stream;
use tokio::sync::mpsc;

#[allow(dead_code)]
pub fn mpsc_receiver_stream<T: Unpin>(
    mut c: mpsc::UnboundedReceiver<T>,
) -> Pin<Box<impl Stream<Item = T>>> {
    Box::pin(stream! {
        while let Some(item) = c.recv().await {
            yield item;
        }
    })
}

#[allow(dead_code)]
#[cfg(unix)]
mod unix_helpers {
    use super::*;

    use tokio::io::AsyncReadExt;

    pub fn unix_read_stream(
        mut r: tokio::net::unix::OwnedReadHalf,
    ) -> Pin<Box<impl Stream<Item = Result<Vec<u8>, String>>>> {
        Box::pin(stream! {
            loop {
                let mut buf = Vec::with_capacity(128);

                yield r.read_buf(&mut buf).await.map_err(|err| err.to_string()).map(|_| buf);
            }
        })
    }
}

#[cfg(unix)]
pub use unix_helpers::*;