Skip to main content

http_type/
lib.rs

1//! http-type
2//!
3//! A comprehensive Rust type library for HTTP operations and concurrent programming.
4
5mod any;
6mod arc_mutex;
7mod arc_rwlock;
8mod attribute;
9mod body;
10mod box_leak;
11mod box_rwlock;
12mod content_type;
13mod cookie;
14mod file_extension;
15mod hash_map_xx_hash3_64;
16mod hash_set_xx_hash3_64;
17mod http_status;
18mod http_url;
19mod http_version;
20mod lifetime;
21mod methods;
22mod panic;
23mod protocol;
24mod rc_rwlock;
25mod request;
26mod response;
27mod status;
28mod stream;
29mod task;
30mod upgrade_type;
31mod websocket_frame;
32
33pub use {
34    any::*, arc_mutex::*, arc_rwlock::*, attribute::*, body::*, box_leak::*, box_rwlock::*,
35    content_type::*, cookie::*, file_extension::*, hash_map_xx_hash3_64::*,
36    hash_set_xx_hash3_64::*, http_status::*, http_url::*, http_version::*, lifetime::*, methods::*,
37    panic::*, protocol::*, rc_rwlock::*, request::*, response::*, status::*, stream::*, task::*,
38    upgrade_type::*, websocket_frame::*,
39};
40
41pub use {http_compress::*, http_constant::*, serde_json, tokio};
42
43use std::{
44    any::Any,
45    cell::{RefCell, RefMut},
46    collections::{HashMap, HashSet, VecDeque, hash_map::Entry},
47    error::Error,
48    fmt::{self, Debug, Display, Formatter, Write},
49    future::{self, Future},
50    hash::Hash,
51    io::{self, ErrorKind},
52    mem,
53    net::{IpAddr, SocketAddr},
54    num::ParseIntError,
55    pin::{Pin, pin},
56    rc::Rc,
57    result::Result,
58    str::{FromStr, SplitWhitespace, from_utf8},
59    sync::{
60        Arc, OnceLock,
61        atomic::{self, AtomicBool, AtomicUsize},
62    },
63    task::{Context, Poll},
64    thread_local,
65    time::Duration,
66};
67
68use {
69    core::hash::BuildHasherDefault,
70    lombok_macros::*,
71    serde::{Deserialize, Serialize, de::DeserializeOwned},
72    tokio::{
73        io::{
74            AsyncBufRead, AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt,
75            ReadBuf,
76        },
77        net::TcpStream,
78        runtime::Handle,
79        sync::{
80            Mutex, Notify, RwLock, RwLockReadGuard, RwLockWriteGuard,
81            mpsc::{UnboundedReceiver, UnboundedSender, unbounded_channel},
82        },
83        task::{JoinError, LocalSet, spawn_blocking, spawn_local},
84        time::{error::Elapsed, timeout},
85    },
86    url::{ParseError, Url},
87};