Document RecvStream::poll_data

src/proto/streams/buffer.rs

@@ -92,13 +92,4 @@ impl Deque {
             None => None,
         }
     }
-
-    /*
-    pub fn peek_front<'a, T>(&self, buf: &'a Buffer<T>) -> Option<&'a T> {
-        match self.indices {
-            Some(idxs) => Some(&buf.slab[idxs.head].value),
-            None => None,
-        }
-    }
-    */
 }

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<Option<Result<Bytes, crate::Error>>> {
         self.inner.inner.poll_data(cx).map_err_(Into::into)
     }

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)));