ntex-h2 3.11.1

An HTTP/2 client and server
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
52
53
54
55
56

use ntex_h2::{Control, Message, client, server};
use ntex_http::uri::Scheme;
use ntex_io::{Io, testing::IoTest};
use ntex_service::{cfg::SharedCfg, fn_service};
use ntex_util::channel::mpsc;

pub mod frames;
mod utils;

pub use self::utils::*;

pub fn start_client(io: IoTest) -> client::SimpleClient {
    io.remote_buffer_cap(1000000);
    client::SimpleClient::new(
        Io::new(io, SharedCfg::default()),
        Scheme::HTTP,
        "localhost".into(),
    )
}

pub fn start_server(io: IoTest) -> mpsc::Receiver<Message> {
    io.remote_buffer_cap(1000000);

    let (tx, rx) = mpsc::channel();
    ntex_util::spawn(async move {
        let _ = server::Server::new(fn_service(move |msg: Message| {
            let _ = tx.send(msg);
            async { Ok(()) }
        }))
        .control(fn_service(|msg: Control<()>| async move {
            log::trace!("Control message: {:?}", msg);
            Ok::<_, ()>(msg.ack())
        }))
        .handler(SharedCfg::default())
        .run(Io::new(io, SharedCfg::default()).into())
        .await;
    });

    rx
}

#[macro_export]
macro_rules! get_headers {
    ($msg: ident) => {{
        use ntex_h2::MessageKind;

        match $msg.kind {
            MessageKind::Headers {
                pseudo,
                headers,
                eof,
            } => (pseudo, headers, eof),
            _ => panic!("unexpected message kind; actual={:?}", $msg),
        }
    }};
}