diff --git a/src/proto/streams/buffer.rs b/src/proto/streams/buffer.rs index 652f2eda1..2648a410e 100644 --- a/src/proto/streams/buffer.rs +++ b/src/proto/streams/buffer.rs @@ -92,13 +92,4 @@ impl Deque { None => None, } } - - /* - pub fn peek_front<'a, T>(&self, buf: &'a Buffer) -> Option<&'a T> { - match self.indices { - Some(idxs) => Some(&buf.slab[idxs.head].value), - None => None, - } - } - */ } diff --git a/src/share.rs b/src/share.rs index 06291068d..eb071dced 100644 --- a/src/share.rs +++ b/src/share.rs @@ -125,11 +125,6 @@ pub struct StreamId(u32); /// See method level documentation for more details on receiving data. See /// [`FlowControl`] for more details on inbound flow control. /// -/// Note that this type implements [`Stream`], yielding the received data frames. -/// When this implementation is used, the capacity is immediately released when -/// the data is yielded. It is recommended to only use this API when the data -/// will not be retained in memory for extended periods of time. -/// /// [`client::ResponseFuture`]: client/struct.ResponseFuture.html /// [`server::Connection`]: server/struct.Connection.html /// [`FlowControl`]: struct.FlowControl.html @@ -406,7 +401,7 @@ impl RecvStream { futures_util::future::poll_fn(move |cx| self.poll_trailers(cx)).await } - #[doc(hidden)] + /// Poll for the next data frame. pub fn poll_data(&mut self, cx: &mut Context<'_>) -> Poll>> { self.inner.inner.poll_data(cx).map_err_(Into::into) } diff --git a/tests/h2-fuzz/src/main.rs b/tests/h2-fuzz/src/main.rs index e67a54071..28905524b 100644 --- a/tests/h2-fuzz/src/main.rs +++ b/tests/h2-fuzz/src/main.rs @@ -119,7 +119,7 @@ async fn run(script: &[u8]) -> Result<(), h2::Error> { fn main() { env_logger::init(); - let mut rt = tokio::runtime::Runtime::new().unwrap(); + let rt = tokio::runtime::Runtime::new().unwrap(); loop { honggfuzz::fuzz!(|data: &[u8]| { eprintln!("{:?}", rt.block_on(run(data)));