Struct Reader 

pub(super) struct Reader<T, F> {
    pub(super) shared: Arc<Shared>,
    pub(super) reader: ReadHalf<T>,
    pub(super) accept: F,
    pub(super) streams: Sender<Stream>,
}

Reads the frames of the client and dispatches them to the streams.

Fields

shared: Arc<Shared>

reader: ReadHalf<T>

accept: F

streams: Sender<Stream>

Implementations

impl<T, F> Reader<T, F>

where T: AsyncRead, F: Fn(&Headers) -> Result<()>,

pub(super) async fn run(self)

Read the frames of the client until the connection ended, then end the streams.

async fn drain(reader: &mut ReadHalf<T>)

Read the client after the end of the connection until it closed it as well, for up to SHUTDOWN_TIMEOUT. A socket closed with input it did not read resets the connection, which can drop the last frames of the server, like the status of a session.

async fn read(&mut self) -> End

async fn open( &mut self, stream_id: u32, fin: bool, headers: Headers, going_away: bool, ) -> Result<()>

Accept or refuse a stream the client opened.