xidl-jsonrpc 0.9.0

A IDL codegen.
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

mod inproc;
mod io;
#[cfg(feature = "quic-s2n")]
mod quic;
#[cfg(feature = "tokio-net")]
mod tcp;
#[cfg(feature = "tokio-tls")]
mod tls;
#[cfg(any(feature = "tokio-tls", feature = "tokio-websocket"))]
mod tls_config;
#[cfg(feature = "tokio-websocket")]
mod websocket;

use std::net::SocketAddr;

pub use inproc::{InprocListener, connect_inproc};
pub use io::IoListener;
#[cfg(feature = "quic-s2n")]
pub use quic::{QuicListener, connect_quic};
#[cfg(feature = "tokio-net")]
pub use tcp::TcpListener;
#[cfg(feature = "tokio-tls")]
pub use tls::{TlsListener, connect_tls};
#[cfg(feature = "tokio-websocket")]
pub use websocket::{WebSocketListener, connect_websocket};

pub trait Stream: tokio::io::AsyncRead + tokio::io::AsyncWrite {}

impl<T> Stream for T where T: tokio::io::AsyncRead + tokio::io::AsyncWrite {}

#[async_trait::async_trait]
pub trait Listener: Send + Sync {
    async fn accept(
        &self,
    ) -> std::io::Result<(Box<dyn Stream + Unpin + Send + 'static>, SocketAddr)>;
}

pub async fn connect(endpoint: &str) -> std::io::Result<Box<dyn Stream + Unpin + Send + 'static>> {
    if let Some(name) = endpoint.strip_prefix("inproc://") {
        return Ok(Box::new(connect_inproc(name)?));
    }

    #[cfg(feature = "quic-s2n")]
    if endpoint.starts_with("quic://") {
        return connect_quic(endpoint).await;
    }

    #[cfg(feature = "tokio-websocket")]
    if endpoint.starts_with("ws://") || endpoint.starts_with("wss://") {
        return connect_websocket(endpoint).await;
    }

    #[cfg(feature = "tokio-tls")]
    if endpoint.starts_with("tls://") {
        return connect_tls(endpoint).await;
    }

    #[cfg(feature = "tokio-net")]
    {
        let addr = endpoint.strip_prefix("tcp://").unwrap_or(endpoint);
        let stream = tokio::net::TcpStream::connect(addr).await?;
        return Ok(Box::new(stream));
    }

    #[cfg(not(feature = "tokio-net"))]
    {
        let _ = endpoint;
        Err(std::io::Error::new(
            std::io::ErrorKind::Unsupported,
            "tcp transport requires `tokio-net` feature",
        ))
    }
}