httpbis 0.9.1

Rust implementation of HTTP/2 protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use crate::result;
use tokio::io::AsyncWrite;

use crate::codec::write_buffer::WriteBuffer;
use crate::solicit::frame::FrameIR;
use bytes::Buf;
use futures::task::Context;
use std::pin::Pin;
use std::task::Poll;

pub struct HttpFramedWrite<W: AsyncWrite + Unpin> {
    write: W,
    buf: WriteBuffer,
}

impl<W: AsyncWrite + Unpin> HttpFramedWrite<W> {
    pub fn new(write: W) -> Self {
        HttpFramedWrite {
            write,
            buf: WriteBuffer::new(),
        }
    }

    pub fn data_len(&self) -> usize {
        self.buf.remaining()
    }

    pub fn buffer_frame<F: FrameIR>(&mut self, frame: F) {
        debug!("send {:?}", frame);

        frame.serialize_into(&mut self.buf);
    }

    pub fn poll_flush(&mut self, cx: &mut Context<'_>) -> Poll<result::Result<()>> {
        loop {
            if !self.buf.has_remaining() {
                return Poll::Ready(Ok(()));
            }

            if let Poll::Pending = Pin::new(&mut self.write).poll_write_buf(cx, &mut self.buf)? {
                return Poll::Pending;
            }
        }
    }
}