move stream generation to new crate

1 files changed, 15 insertions, 0 deletions

diff --git a/stream/src/lib.rs b/stream/src/lib.rs
new file mode 100644
index 0000000..df75cf5
--- /dev/null
+++ b/stream/src/lib.rs
@@ -0,0 +1,15 @@
+use jellycommon::{stream::StreamSpec, Node};
+use std::ops::Range;
+use tokio::io::{duplex, DuplexStream};
+use tokio_util::io::SyncIoBridge;
+
+pub async fn stream(
+    node: Node,
+    spec: StreamSpec,
+    range: Range<usize>,
+) -> anyhow::Result<DuplexStream> {
+    let (a, b) = duplex(4096);
+    let b = SyncIoBridge::new(b);
+
+    Ok(a)
+}