deaddrop-net 2.6.0

DeadDrop networking: transports, discovery, sync, routing, scheduler
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

use crate::transport::{ByteStream, Transport, TransportCaps};
use async_trait::async_trait;
use deaddrop_core::{DdError, Result};
use tokio::net::TcpStream;

pub struct TcpTransport;

#[async_trait]
impl Transport for TcpTransport {
    fn name(&self) -> &'static str {
        "tcp"
    }
    fn capabilities(&self) -> TransportCaps {
        TransportCaps {
            encrypted: false,
            multiplex: false,
            migration: false,
        }
    }
    async fn connect(&self, locator: &str) -> Result<Box<dyn ByteStream>> {
        let s = TcpStream::connect(locator).await.map_err(DdError::from)?;
        Ok(Box::new(s))
    }
}