Struct Http2Session 

pub struct Http2Session {
    pub read_timeout: Option<Duration>,
    pub write_timeout: Option<Duration>,
    /* private fields */
}

Fields

read_timeout: Option<Duration>

The read timeout, which will be applied to both reading the header and the body. The timeout is reset on every read. This is not a timeout on the overall duration of the response.

write_timeout: Option<Duration>

The write timeout which will be applied to writing request body. The timeout is reset on every write. This is not a timeout on the overall duration of the request.

Implementations

impl Http2Session

pub fn write_request_header( &mut self, req: Box<RequestHeader>, end: bool, ) -> Result<(), Box<Error>>

Write the request header to the server

pub async fn write_request_body( &mut self, data: Bytes, end: bool, ) -> Result<(), Box<Error>>

Write a request body chunk

pub async fn do_write_request_body( &mut self, data: Bytes, end: bool, ) -> Result<(), Box<Error>>

pub fn finish_request_body(&mut self) -> Result<(), Box<Error>>

Signal that the request body has ended

pub async fn read_response_header(&mut self) -> Result<(), Box<Error>>

Read the response header

pub async fn read_response_body(&mut self) -> Result<Option<Bytes>, Box<Error>>

Read the response body

None means, no more body to read

pub fn response_finished(&self) -> bool

Whether the response has ended

pub fn check_response_end_or_error(&mut self) -> Result<bool, Box<Error>>

Check whether stream finished with error. Like response_finished, but also attempts to poll the h2 stream for errors that may have caused the stream to terminate, and returns them as H2Errors.

pub async fn read_trailers(&mut self) -> Result<Option<HeaderMap>, Box<Error>>

Read the optional trailer headers

pub fn request_header(&self) -> Option<&RequestHeader>

The request header if it is already sent

pub fn response_header(&self) -> Option<&ResponseHeader>

The response header if it is already read

pub fn shutdown(&mut self)

Give up the http session abruptly.

pub fn digest(&self) -> Option<&Digest>

Return the Digest of the connection

For reused connection, the timing in the digest will reflect its initial handshakes The caller should check if the connection is reused to avoid misuse the timing field.

pub fn digest_mut(&mut self) -> Option<&mut Digest>

Return a mutable Digest reference for the connection

Will return None if multiple H2 streams are open.

pub fn server_addr(&self) -> Option<&SocketAddr>

Return the server (peer) address recorded in the connection digest.

pub fn client_addr(&self) -> Option<&SocketAddr>

Return the client (local) address recorded in the connection digest.

pub fn fd(&self) -> i32

the FD of the underlying connection

pub fn take_request_body_writer(&mut self) -> Option<SendStream<Bytes>>

take the body sender to another task to perform duplex read and write

Trait Implementations

impl Drop for Http2Session

fn drop(&mut self)

Executes the destructor for this type.