aboutsummaryrefslogtreecommitdiff
path: root/stream/src
diff options
context:
space:
mode:
Diffstat (limited to 'stream/src')
-rw-r--r--stream/src/lib.rs15
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)
+}