http-type 18.3.1

A comprehensive Rust type library for HTTP operations and concurrent programming. Provides core HTTP types (Request/Response with builder patterns, Method, HttpStatus, HttpVersion, ContentType, FileExtension with MIME mapping, Cookie parsing/building, HttpUrl parsing, WebSocket frame/opcode, protocol upgrade types, stream/task management, panic handling), thread-safe concurrent wrappers (ArcMutex, ArcRwLock, BoxRwLock, RcRwLock), dynamic dispatch types (BoxAny, RcAny, ArcAny with Send/Sync variants), high-performance hash collections (HashMapXxHash3_64, HashSetXxHash3_64), and static lifetime utilities (BoxLeak, Lifetime trait).
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
79
80
81
82
83
84
85

//! http-type
//!
//! A comprehensive Rust type library for HTTP operations and concurrent programming.
//! Provides core HTTP types (Request/Response with builder patterns, Method, HttpStatus, HttpVersion,
//! ContentType, FileExtension with MIME mapping, Cookie parsing/building, HttpUrl parsing,
//! WebSocket frame/opcode, protocol upgrade types, stream/task management, panic handling),
//! thread-safe concurrent wrappers (ArcMutex, ArcRwLock, BoxRwLock, RcRwLock),
//! dynamic dispatch types (BoxAny, RcAny, ArcAny with Send/Sync variants),
//! high-performance hash collections (HashMapXxHash3_64, HashSetXxHash3_64),
//! and static lifetime utilities (BoxLeak, Lifetime trait).

mod any;
mod arc_mutex;
mod arc_rwlock;
mod attribute;
mod box_leak;
mod box_rwlock;
mod content_type;
mod cookie;
mod file_extension;
mod hash_map_xx_hash3_64;
mod hash_set_xx_hash3_64;
mod http_status;
mod http_url;
mod http_version;
mod lifetime;
mod methods;
mod panic;
mod protocol;
mod rc_rwlock;
mod request;
mod response;
mod status;
mod stream;
mod task;
mod upgrade_type;
mod websocket_frame;

pub use {
    any::*, arc_mutex::*, arc_rwlock::*, attribute::*, box_leak::*, box_rwlock::*, content_type::*,
    cookie::*, file_extension::*, hash_map_xx_hash3_64::*, hash_set_xx_hash3_64::*, http_status::*,
    http_url::*, http_version::*, lifetime::*, methods::*, panic::*, protocol::*, rc_rwlock::*,
    request::*, response::*, status::*, stream::*, task::*, upgrade_type::*, websocket_frame::*,
};

pub use {http_compress::*, http_constant::*, serde_json, tokio};

use std::{
    any::Any,
    collections::{HashMap, HashSet, VecDeque},
    fmt::{self, Debug, Display},
    hash::Hash,
    io::ErrorKind,
    net::IpAddr,
    num::ParseIntError,
    pin::Pin,
    rc::Rc,
    result::Result,
    str::{FromStr, SplitWhitespace},
    sync::{
        Arc,
        atomic::{self, AtomicBool, AtomicUsize},
    },
    time::Duration,
};

#[cfg(test)]
use tokio::{spawn, task::JoinHandle};
use {
    core::hash::BuildHasherDefault,
    lombok_macros::*,
    serde::{Deserialize, Serialize, de::DeserializeOwned},
    tokio::{
        io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt, BufReader},
        net::TcpStream,
        runtime::Handle,
        sync::{
            Mutex, Notify, RwLock, RwLockReadGuard, RwLockWriteGuard,
            mpsc::{UnboundedReceiver, UnboundedSender, unbounded_channel},
        },
        task::{JoinError, LocalSet, spawn_blocking, spawn_local},
        time::{error::Elapsed, timeout},
    },
    url::{ParseError, Url},
};