rama-net 0.3.0

rama network types and utilities
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

use crate::address::SocketAddress;

use rama_core::{Service, error::BoxError};

/// Glue trait that is used as the trait bound for
/// code creating/preparing a socket on one layer or another.
///
/// Can also be manually implemented as an alternative [`Service`] trait,
/// but from a Rama POV it is mostly used for UX trait bounds.
pub trait SocketService: Send + Sync + 'static {
    /// Socket returned by the [`SocketService`]
    type Socket: Send + 'static;
    /// Error returned in case of connection / setup failure
    type Error: Into<BoxError> + Send + 'static;

    /// Create a binding to a Unix/Linux/Windows socket.
    fn bind_socket_with_address(
        &self,
        addr: impl Into<SocketAddress>,
    ) -> impl Future<Output = Result<Self::Socket, Self::Error>> + Send + '_;
}

impl<S, Socket> SocketService for S
where
    S: Service<SocketAddress, Output = Socket, Error: Into<BoxError> + Send + 'static>,
    Socket: Send + 'static,
{
    type Socket = Socket;
    type Error = S::Error;

    fn bind_socket_with_address(
        &self,
        addr: impl Into<SocketAddress>,
    ) -> impl Future<Output = Result<Self::Socket, Self::Error>> + Send + '_ {
        self.serve(addr.into())
    }
}