stream/src/lib.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
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)
}