coap 0.27.0

A CoAP library
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

#![feature(test)]
extern crate test;

use std::net::SocketAddr;

use coap::{server::UdpCoapListener, Server, UdpCoAPClient};
use coap_lite::{CoapOption, CoapRequest, MessageType};
use tokio::{net::UdpSocket, runtime::Runtime};

#[bench]
fn bench_server_with_request(b: &mut test::Bencher) {
    let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel();

    let rt = Runtime::new().unwrap();
    rt.spawn(async move {
        let sock = UdpSocket::bind("127.0.0.1:0").await.unwrap();
        let addr = sock.local_addr().unwrap();
        let listener = Box::new(UdpCoapListener::from_socket(sock));
        let server = Server::from_listeners(vec![listener]);

        tx.send(addr.port()).unwrap();

        server
            .run(move |mut request: Box<CoapRequest<SocketAddr>>| async {
                let uri_path = request.get_path().to_string();

                if let Some(ref mut response) = request.response {
                    response.message.payload = uri_path.as_bytes().to_vec();
                };
                request
            })
            .await
            .unwrap();
    });

    let server_port = rx.blocking_recv().unwrap();
    let client = rt.block_on(async {
        UdpCoAPClient::new(format!("127.0.0.1:{}", server_port))
            .await
            .unwrap()
    });

    let mut request = CoapRequest::new();
    request.message.header.set_version(1);
    request.message.header.set_type(MessageType::Confirmable);
    request.message.header.set_code("0.01");
    request.message.header.message_id = 1;
    request.message.set_token(vec![0x51, 0x55, 0x77, 0xE8]);
    request
        .message
        .add_option(CoapOption::UriPath, "test".to_string().into_bytes());

    b.iter(|| {
        rt.block_on(async {
            let recv_packet = client.send(request.clone()).await.unwrap();
            assert_eq!(recv_packet.message.payload, b"test".to_vec());
        });
    });
}