noxious 1.0.4

The core library for noxious, a Rust port of Toxiproxy
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

use crate::socket::{ReadStream, SocketListener, SocketStream, WriteStream};
use async_trait::async_trait;
use mockall::mock;
use std::{io, net::SocketAddr};

mock! {
    pub MemoryListener {}

    #[async_trait]
    impl SocketListener for MemoryListener {
        type Stream = MockMemoryStream;

        async fn bind(addr: &str) -> io::Result<Self>
        where
            Self: Sized;

        async fn accept(&self) -> io::Result<(MockMemoryStream, SocketAddr)>;
    }
}

mock! {
    pub MemoryStream {}

    #[async_trait]
    impl SocketStream for MemoryStream {
        async fn connect(addr: &str) -> io::Result<Self>
        where
            Self: Sized + 'static;

        fn into_split(self) -> (ReadStream, WriteStream);
    }
}