diff --git a/local_test.yaml b/local_test.yaml index a33b03b..843db8a 100644 --- a/local_test.yaml +++ b/local_test.yaml @@ -8,7 +8,7 @@ routes: virtual_device: "mic" device: local: - name: "VoiceMeeter Output (VB-Audio VoiceMeeter VAIO)" + name: "VoiceMeeter Aux Output (VB-Audio VoiceMeeter AUX VAIO)" output: - name: "Speaker" input: diff --git a/src/commands/run.rs b/src/commands/run.rs index d2190e8..7106109 100644 --- a/src/commands/run.rs +++ b/src/commands/run.rs @@ -108,10 +108,11 @@ pub fn run(run: Run) { let config = device.default_input_config().unwrap(); let channels = config.channels(); let virtual_devices = virtual_devices.iter().filter(|device| device.lock().unwrap().name == input_route.virtual_device).map(|d| d.clone()).collect::>(); - let mut stream = device.build_input_stream( + let stream = device.build_input_stream( &config.into(), { move |data, _| { + println!("Reading input stream"); for (i, buffer) in data.chunks(channels as usize).enumerate() { let buffer = buffer.to_vec(); for virtual_device in &virtual_devices { @@ -123,6 +124,7 @@ pub fn run(run: Run) { move |err| eprintln!("An error occurred on the input stream: {}", err), None ).unwrap(); + println!("Playing input stream"); stream.play().unwrap(); } crate::config::Device::Remote { remote } => { @@ -130,4 +132,6 @@ pub fn run(run: Run) { } } } + + std::thread::sleep(std::time::Duration::from_secs(10)); } diff --git a/src/device/virtual_device.rs b/src/device/virtual_device.rs index 82e4e82..a306e2d 100644 --- a/src/device/virtual_device.rs +++ b/src/device/virtual_device.rs @@ -28,6 +28,7 @@ impl VirtualDevice { } pub fn take_output(&mut self, index: usize, channel: u8, take_size: usize) -> Option> { + println!("Min index: {}", self.get_min_index()); let mut buffer = Vec::with_capacity(take_size); let start = self.output_index[index]; let end = start + take_size; @@ -55,6 +56,7 @@ impl VirtualDevice { } pub fn write_input(&mut self, channel: u8, buffer: Vec) { + println!("Writing input to virtual device: {} {:?}", self.name, buffer); self.output_buffer[channel as usize].extend(buffer); } } \ No newline at end of file