Tahinli/radioxide
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

perf: ⚡ I was wasting first decoded samples

Browse source
This commit is contained in:
Ahmet Kaan GÜMÜŞ 2024-07-26 21:35:22 +03:00
parent 399d5116eb
commit 204b912025
1 changed files with 17 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

21
streamer/src/playing.rs
View file

@ -211,10 +211,15 @@ async fn process_audio(
window: WindowFunction::BlackmanHarris2,
};
let chunk_size = match decode_audio(&mut format, track_id, &mut decoder) {
Some((audio_decoded_left_channel, _)) => audio_decoded_left_channel.len(),
None => return,
};
let (chunk_size, audio_decoded_left, audio_decoded_right) =
match decode_audio(&mut format, track_id, &mut decoder) {
Some((audio_decoded_left_channel, audio_decoded_right_channel)) => (
audio_decoded_left_channel.len(),
audio_decoded_left_channel,
audio_decoded_right_channel,
),
None => return,
};
let mut resampler = SincFixedIn::<f64>::new(
output_device_sample_rate as f64 / audio_sample_rate as f64,
@ -225,6 +230,14 @@ async fn process_audio(
)
.unwrap();
let (audio_resampled_left, audio_resampled_right) =
resample_audio(audio_decoded_left, audio_decoded_right, &mut resampler);
for (single_left, single_right) in audio_resampled_left.iter().zip(&audio_resampled_right) {
let _ = decoded_to_playing_sender.send(*single_left as f32);
let _ = decoded_to_playing_sender.send(*single_right as f32);
}
loop {
let (mut audio_decoded_left, mut audio_decoded_right) = (vec![], vec![]);