2021-02-11 23:39:54 +01:00
|
|
|
//! HTTP/2 protocol.
|
2021-01-04 01:49:02 +01:00
|
|
|
|
|
|
|
use std::{
|
|
|
|
pin::Pin,
|
|
|
|
task::{Context, Poll},
|
|
|
|
};
|
2019-02-02 05:18:44 +01:00
|
|
|
|
2019-02-06 20:44:15 +01:00
|
|
|
use bytes::Bytes;
|
2021-01-04 01:49:02 +01:00
|
|
|
use futures_core::{ready, Stream};
|
2019-02-06 20:44:15 +01:00
|
|
|
use h2::RecvStream;
|
|
|
|
|
|
|
|
mod dispatcher;
|
2019-02-02 05:18:44 +01:00
|
|
|
mod service;
|
|
|
|
|
2019-03-07 07:56:34 +01:00
|
|
|
pub use self::dispatcher::Dispatcher;
|
2019-02-06 20:44:15 +01:00
|
|
|
pub use self::service::H2Service;
|
|
|
|
use crate::error::PayloadError;
|
|
|
|
|
2021-01-04 01:49:02 +01:00
|
|
|
/// HTTP/2 peer stream.
|
2019-02-06 20:44:15 +01:00
|
|
|
pub struct Payload {
|
2021-01-04 01:49:02 +01:00
|
|
|
stream: RecvStream,
|
2019-02-06 20:44:15 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
impl Payload {
|
2021-01-04 01:49:02 +01:00
|
|
|
pub(crate) fn new(stream: RecvStream) -> Self {
|
|
|
|
Self { stream }
|
2019-02-06 20:44:15 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
impl Stream for Payload {
|
2019-11-15 10:54:11 +01:00
|
|
|
type Item = Result<Bytes, PayloadError>;
|
|
|
|
|
2019-12-07 19:46:51 +01:00
|
|
|
fn poll_next(
|
|
|
|
self: Pin<&mut Self>,
|
|
|
|
cx: &mut Context<'_>,
|
|
|
|
) -> Poll<Option<Self::Item>> {
|
2019-11-15 10:54:11 +01:00
|
|
|
let this = self.get_mut();
|
2019-02-06 20:44:15 +01:00
|
|
|
|
2021-01-04 01:49:02 +01:00
|
|
|
match ready!(Pin::new(&mut this.stream).poll_data(cx)) {
|
|
|
|
Some(Ok(chunk)) => {
|
2019-02-06 20:44:15 +01:00
|
|
|
let len = chunk.len();
|
2021-01-04 01:49:02 +01:00
|
|
|
|
|
|
|
match this.stream.flow_control().release_capacity(len) {
|
|
|
|
Ok(()) => Poll::Ready(Some(Ok(chunk))),
|
|
|
|
Err(err) => Poll::Ready(Some(Err(err.into()))),
|
2019-02-06 20:44:15 +01:00
|
|
|
}
|
|
|
|
}
|
2021-01-04 01:49:02 +01:00
|
|
|
Some(Err(err)) => Poll::Ready(Some(Err(err.into()))),
|
|
|
|
None => Poll::Ready(None),
|
2019-02-06 20:44:15 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|