motore 0.4.1

Motore is a library of modular and reusable components for building robust clients and servers. Motore is greatly inspired by Tower.
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

use futures::Future;
use tokio::io::{AsyncRead, AsyncWrite};

use crate::{sealed::Sealed, UnaryService};

/// This trait is used to create a connection.
///
/// The connection can either be a real connection or a virtual connection,
/// which means that we only ask for something that is `AsyncRead + AsyncWrite`.
/// A typical example of a virtual connection is a HTTP/2 stream.
pub trait MakeConnection<Address>: Sealed<(Address,)> {
    type Connection: AsyncRead + AsyncWrite + Unpin + Send;
    type Error;

    #[cfg(feature = "service_send")]
    fn make_connection(
        &self,
        req: Address,
    ) -> impl Future<Output = Result<Self::Connection, Self::Error>> + Send;
    #[cfg(not(feature = "service_send"))]
    fn make_connection(
        &self,
        req: Address,
    ) -> impl Future<Output = Result<Self::Connection, Self::Error>>;
}

impl<S, Address> Sealed<(Address,)> for S where S: UnaryService<Address> {}

impl<S, Address> MakeConnection<Address> for S
where
    S: UnaryService<Address>,
    S::Response: AsyncRead + AsyncWrite + Unpin + Send,
{
    type Connection = S::Response;
    type Error = S::Error;

    #[cfg(feature = "service_send")]
    fn make_connection(
        &self,
        addr: Address,
    ) -> impl Future<Output = Result<Self::Connection, Self::Error>> + Send {
        self.call(addr)
    }
    #[cfg(not(feature = "service_send"))]
    fn make_connection(
        &self,
        addr: Address,
    ) -> impl Future<Output = Result<Self::Connection, Self::Error>> {
        self.call(addr)
    }
}