http-type 22.0.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
86
87

//! http-type
//!
//! A comprehensive Rust type library for HTTP operations and concurrent programming.

mod any;
mod arc_mutex;
mod arc_rwlock;
mod attribute;
mod body;
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::*, body::*, 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,
    cell::{RefCell, RefMut},
    collections::{HashMap, HashSet, VecDeque, hash_map::Entry},
    error::Error,
    fmt::{self, Debug, Display, Formatter, Write},
    future::{self, Future},
    hash::Hash,
    io::{self, ErrorKind},
    mem,
    net::{IpAddr, SocketAddr},
    num::ParseIntError,
    pin::{Pin, pin},
    rc::Rc,
    result::Result,
    str::{FromStr, SplitWhitespace, from_utf8},
    sync::{
        Arc, OnceLock,
        atomic::{self, AtomicBool, AtomicUsize},
    },
    task::{Context, Poll},
    thread_local,
    time::Duration,
};

use {
    core::hash::BuildHasherDefault,
    lombok_macros::*,
    serde::{Deserialize, Serialize, de::DeserializeOwned},
    tokio::{
        io::{
            AsyncBufRead, AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt,
            ReadBuf,
        },
        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},
};