Enum Scheme 

pub enum Scheme {
    Http(Arc<Mutex<TcpStream>>),
    Https(Arc<Mutex<StreamOwned<ServerConnection, TcpStream>>>),
}

Variants

Http(Arc<Mutex<TcpStream>>)

Https(Arc<Mutex<StreamOwned<ServerConnection, TcpStream>>>)

Implementations

impl Scheme

pub fn split_for_websocket( scheme: &Arc<Mutex<Scheme>>, ) -> Result<(SchemeReader, SchemeWriter), HttpError>

impl Scheme

pub fn read(&mut self, data: &mut Vec<u8>) -> Result<(), HttpError>

读取

pub fn write(&mut self, data: &[u8]) -> Result<(), HttpError>

写入

pub fn write_all(&mut self, data: &[u8]) -> Result<(), HttpError>

pub fn flush(&mut self) -> Result<(), HttpError>

pub fn read_ws_data( &mut self, deflate: &DeflateConfig, ) -> Result<Message, HttpError>

pub fn client_ip(&mut self) -> String

pub fn server_ip(&mut self) -> String

pub fn http2_packet( &mut self, init_data: &mut Vec<u8>, ) -> Result<(Vec<u8>, FrameType, u8, u32), HttpError>

读取HTTP2

pub fn http2_handle_header( &mut self, data: &mut Vec<u8>, request: &mut Request, ) -> Result<(), HttpError>

读取HTTP2消息头

pub fn http2_handle_body( &mut self, data: &mut Vec<u8>, request: Request, ) -> Result<Vec<u8>, HttpError>

读取HTTP2消息体

pub fn http2_send_server_settings(&mut self) -> Result<(), HttpError>

发送HTTP2认证参数

pub fn http2_settings_ack(&mut self) -> Result<(), HttpError>

发送对“对端 SETTINGS”的 ACK（len=0, flags=ACK）

pub fn http2_goaway( &mut self, last_stream_id: u32, error_code: u32, ) -> Result<(), HttpError>

Trait Implementations

impl Clone for Scheme

fn clone(&self) -> Scheme

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Scheme

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.