ntex-h2 3.9.2

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
57
58
59
60
61
62
63
64
65
66
67
68

use ntex::service::{cfg::SharedCfg, fn_service};
use ntex_error::Error;
use ntex_h2::{Control, Message, MessageKind, OperationError, ServiceConfig, server};
use ntex_http::{HeaderMap, StatusCode, header};
use ntex_util::time::{Millis, sleep};

#[ntex::main]
async fn main() -> std::io::Result<()> {
    let _ = env_logger::try_init();

    ntex::server::build()
        .bind("http", "127.0.0.1:5928", async move |_| {
            server::Server::new(fn_service(async move |msg: Message| {
                let Message { stream, kind } = msg;
                match kind {
                    MessageKind::Headers {
                        pseudo,
                        headers,
                        eof,
                    } => {
                        log::trace!(
                            "{:?} got request (eof: {}): {:#?}\nheaders: {:#?}",
                            stream.id(),
                            eof,
                            pseudo,
                            headers
                        );
                        // return Err(());
                        let mut hdrs = HeaderMap::default();
                        hdrs.insert(
                            header::CONTENT_TYPE,
                            header::HeaderValue::try_from("text/plain").unwrap(),
                        );
                        stream.send_response(StatusCode::OK, hdrs, false)?;

                        if eof {
                            sleep(Millis(150)).await;
                            log::trace!("Sending payload for {:?}", stream.id(),);
                            stream.send_payload("hello world".into(), true).await?;
                        }
                    }
                    MessageKind::Data(data, _cap) => {
                        log::trace!("Got data: {:?}", data.len());
                    }
                    MessageKind::Eof(data) => {
                        log::trace!("Got eof: {:?}", data);
                        stream.send_payload("hello world".into(), true).await?;
                    }
                    MessageKind::Disconnect(err) => {
                        log::trace!("Disconnect: {:?}", err);
                    }
                }
                Ok::<_, Error<OperationError>>(())
            }))
            .control(|msg: Control<_>| async move {
                log::trace!("Control message: {:?}", msg);
                Ok::<_, ()>(msg.ack())
            })
        })?
        .config(
            "http",
            SharedCfg::new("SRV").add(ServiceConfig::new().set_max_concurrent_streams(10)),
        )
        .workers(1)
        .stop_runtime()
        .run()
        .await
}