trillium-testing 0.10.0

testing library for trillium applications
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

use super::SERVERS;
use crate::{RuntimelessRuntime, TestTransport};
use std::{
    io::{Error, ErrorKind, Result},
    net::SocketAddr,
};
use trillium_server_common::Connector;
use url::Url;

/// An in-memory Connector to use with RuntimelessServer.
#[derive(Default, Debug, Clone, Copy)]
pub struct RuntimelessClientConfig(());

impl RuntimelessClientConfig {
    /// constructs a RuntimelessClientConfig
    pub fn new() -> Self {
        Self(())
    }
}

impl Connector for RuntimelessClientConfig {
    type Runtime = RuntimelessRuntime;
    type Transport = TestTransport;
    type Udp = ();

    async fn connect(&self, url: &Url) -> Result<Self::Transport> {
        let (tx, _) = &*SERVERS
            .get(&(
                url.host_str().unwrap().to_string(),
                url.port_or_known_default().unwrap(),
            ))
            .ok_or(Error::new(ErrorKind::AddrNotAvailable, "not available"))?;
        let (client_transport, server_transport) = TestTransport::new();
        tx.send(server_transport).await.unwrap();
        Ok(client_transport)
    }

    fn runtime(&self) -> Self::Runtime {
        RuntimelessRuntime::default()
    }

    async fn resolve(&self, _host: &str, _port: u16) -> Result<Vec<SocketAddr>> {
        Ok(vec![])
    }
}