proxmox-async: split blocking.rs into separate files

proxmox-async/src/blocking/mod.rs

@@ -0,0 +1,8 @@
+//! Async wrappers for blocking I/O (adding `block_in_place` around
+//! channels/readers)
+
+mod std_channel_stream;
+pub use std_channel_stream::StdChannelStream;
+
+mod wrapped_reader_stream;
+pub use wrapped_reader_stream::WrappedReaderStream;

proxmox-async/src/blocking/std_channel_stream.rs

@@ -0,0 +1,21 @@
+use std::pin::Pin;
+use std::task::{Context, Poll};
+use std::sync::mpsc::Receiver;
+
+use futures::stream::Stream;
+
+use crate::runtime::block_in_place;
+
+/// Wrapper struct to convert a channel Receiver into a Stream
+pub struct StdChannelStream<T>(pub Receiver<T>);
+
+impl<T> Stream for StdChannelStream<T> {
+    type Item = T;
+
+    fn poll_next(self: Pin<&mut Self>, _cx: &mut Context) -> Poll<Option<Self::Item>> {
+        match block_in_place(|| self.0.recv()) {
+            Ok(data) => Poll::Ready(Some(data)),
+            Err(_) => Poll::Ready(None),// channel closed
+        }
+    }
+}

proxmox-async/src/blocking/wrapped_reader_stream.rs

@@ -1,9 +1,6 @@
-//! Async wrappers for blocking I/O (adding `block_in_place` around channels/readers)
-
 use std::io::{self, Read};
 use std::pin::Pin;
 use std::task::{Context, Poll};
-use std::sync::mpsc::Receiver;
 
 use futures::stream::Stream;
 
@@ -43,20 +40,6 @@ impl<R: Read + Unpin> Stream for WrappedReaderStream<R> {
     }
 }
 
-/// Wrapper struct to convert a channel Receiver into a Stream
-pub struct StdChannelStream<T>(pub Receiver<T>);
-
-impl<T> Stream for StdChannelStream<T> {
-    type Item = T;
-
-    fn poll_next(self: Pin<&mut Self>, _cx: &mut Context) -> Poll<Option<Self::Item>> {
-        match block_in_place(|| self.0.recv()) {
-            Ok(data) => Poll::Ready(Some(data)),
-            Err(_) => Poll::Ready(None),// channel closed
-        }
-    }
-}
-
 #[cfg(test)]
 mod test {
     use std::io;