From a27ecba29b7e8af4648713c36175511861a09945 Mon Sep 17 00:00:00 2001 From: Muaz Ahmad Date: Fri, 6 Oct 2023 12:43:53 +0500 Subject: [PATCH] basic init implementation --- src/demux/mod.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/demux/mod.rs b/src/demux/mod.rs index f84670e..cf7168c 100644 --- a/src/demux/mod.rs +++ b/src/demux/mod.rs @@ -5,6 +5,7 @@ use std::sync::mpsc; use std::error::Error; use crate::util; +use crate::demux::input::FileReader; pub fn spawn() -> Result< ( @@ -15,5 +16,10 @@ pub fn spawn() -> Result< ), Box > { - todo!(); + let mut reader = input::new_reader()?; + let metadata = reader.init()?; + let (_v_in, v_out) = mpsc::channel(); + let (_a_in, a_out) = mpsc::channel(); + let (_err_in, err_out) = mpsc::channel(); + return Ok((v_out, a_out, metadata, err_out)); }