hyperlane 20.0.1

A lightweight, high-performance, and cross-platform Rust HTTP server library built on Tokio. It simplifies modern web service development by providing built-in support for middleware, WebSocket, Server-Sent Events (SSE), and raw TCP communication. With a unified and ergonomic API across Windows, Linux, and MacOS, it enables developers to build robust, scalable, and event-driven network applications with minimal overhead and maximum flexibility.
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
69
70
71
72
73
74
75
76
77
78

use crate::*;

#[tokio::test]
async fn task_clone() {
    let task1: Task = Task::default();
    let task2: Task = task1.clone();
    assert_eq!(task1.get_pool().len(), task2.get_pool().len());
    assert_eq!(
        task1.get_counter().load(atomic::Ordering::Relaxed),
        task2.get_counter().load(atomic::Ordering::Relaxed)
    );
    assert_eq!(
        task1.get_shutdown().load(atomic::Ordering::Relaxed),
        task2.get_shutdown().load(atomic::Ordering::Relaxed)
    );
}

#[tokio::test]
async fn task_default() {
    let task: Task = Task::default();
    let worker_count: usize = Handle::current().metrics().num_workers();
    if worker_count > 0 {
        assert_eq!(task.get_pool().len(), worker_count);
    }
    assert_eq!(task.get_counter().load(atomic::Ordering::Relaxed), 0);
    assert!(!task.get_shutdown().load(atomic::Ordering::Relaxed));
}

#[tokio::test]
async fn task_try_spawn_local_with_index() {
    let task: Task = Task::default();
    if task.get_pool().is_empty() {
        return;
    }
    let result: bool = task.try_spawn_local(Some(0), async move {});
    assert!(result);
}

#[tokio::test]
async fn task_try_spawn_local_round_robin() {
    let task: Task = Task::default();
    if task.get_pool().is_empty() {
        return;
    }
    let result: bool = task.try_spawn_local(None, async move {});
    assert!(result);
}

#[tokio::test]
async fn task_try_spawn_local_empty_pool() {
    let task: Task = Task {
        pool: Vec::new(),
        counter: Arc::new(AtomicUsize::new(0)),
        shutdown: Arc::new(AtomicBool::new(false)),
        notifies: Vec::new(),
    };
    let result: bool = task.try_spawn_local(None, async move {});
    assert!(!result);
}

#[tokio::test]
async fn task_try_spawn_local_with_large_index() {
    let task: Task = Task::default();
    if task.get_pool().is_empty() {
        return;
    }
    let large_index: usize = task.get_pool().len() + 100;
    let result: bool = task.try_spawn_local(Some(large_index), async move {});
    assert!(result);
}

#[tokio::test]
async fn task_shutdown() {
    let task: Task = Task::default();
    assert!(!task.get_shutdown().load(atomic::Ordering::Relaxed));
    task.shutdown();
    assert!(task.get_shutdown().load(atomic::Ordering::Relaxed));
}