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},
47    error::Error,
48    fmt::{self, Debug, Display, Formatter, Write},
49    hash::Hash,
50    io::{self, ErrorKind},
51    mem,
52    net::{IpAddr, SocketAddr},
53    num::ParseIntError,
54    pin::Pin,
55    rc::Rc,
56    result::Result,
57    str::{FromStr, SplitWhitespace, from_utf8},
58    sync::{
59        Arc,
60        atomic::{self, AtomicBool, AtomicUsize},
61    },
62    task::{Context, Poll},
63    thread_local,
64    time::Duration,
65};
66
67use {
68    core::hash::BuildHasherDefault,
69    lombok_macros::*,
70    serde::{Deserialize, Serialize, de::DeserializeOwned},
71    tokio::{
72        io::{
73            AsyncBufRead, AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt,
74            ReadBuf,
75        },
76        net::TcpStream,
77        runtime::Handle,
78        sync::{
79            Mutex, Notify, RwLock, RwLockReadGuard, RwLockWriteGuard,
80            mpsc::{UnboundedReceiver, UnboundedSender, unbounded_channel},
81        },
82        task::{JoinError, LocalSet, spawn_blocking, spawn_local},
83        time::{error::Elapsed, timeout},
84    },
85    url::{ParseError, Url},
86};