streaming: next_frame

Author: ifdario

src/native/streaming.rs

@@ -50,6 +50,7 @@
 
 use std::{
     collections::VecDeque,
+    future::poll_fn,
     pin::Pin,
     sync::Arc,
     task::{ready, Context, Poll},
@@ -192,6 +193,11 @@ where
         }
     }
 
+    /// Asynchronously retrieves the next frame from the WebSocket stream.
+    pub async fn next_frame(&mut self) -> Result<Frame> {
+        poll_fn(|cx| self.poll_next_frame(cx)).await
+    }
+
     /// Splits the `Streaming` connection into its low-level components for advanced usage.
     ///
     /// This method provides access to the underlying framed stream and read/write halves,