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;
use http_type::*;
use std::{
collections::VecDeque,
fmt::{self, Debug, Formatter},
io::{self, ErrorKind},
mem,
net::SocketAddr,
num::ParseIntError,
pin::Pin,
ptr,
rc::Rc,
result::Result,
sync::{
Arc,
atomic::{self, AtomicBool, AtomicUsize},
},
task::{Context, Poll},
};
use {
serde::Deserialize,
tokio::{
io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt, DuplexStream, ReadBuf, duplex},
net::{TcpListener, TcpStream},
runtime::Handle,
spawn,
sync::{RwLockReadGuard, RwLockWriteGuard},
task::{JoinError, JoinHandle, yield_now},
time::{Duration, error::Elapsed, sleep},
},
url::{ParseError, Url},
};