From e44bef20217fb329fd539feb986165d3c9521ddf Mon Sep 17 00:00:00 2001 From: Claude Date: Wed, 12 Nov 2025 10:38:58 +0000 Subject: [PATCH] Fix StreamingFlacSink parameter confusion --- pmoparadise/examples/stream_block.rs | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/pmoparadise/examples/stream_block.rs b/pmoparadise/examples/stream_block.rs index 43fbaea8..7355f259 100644 --- a/pmoparadise/examples/stream_block.rs +++ b/pmoparadise/examples/stream_block.rs @@ -218,8 +218,9 @@ async fn main() -> Result<(), Box> { let mut timer_flac = TimerNode::with_channel_size(max_lead_time, channel_size); tracing::debug!("TimerNode (FLAC) created with {:.1}s max lead time, {} chunk buffer", max_lead_time, channel_size); - let (streaming_sink, stream_handle) = StreamingFlacSink::new(encoder_options.clone(), channel_size.min(255) as u8); - tracing::debug!("StreamingFlacSink created with {} chunk buffer", channel_size); + // StreamingFlacSink doesn't take channel_size - it uses bits_per_sample (16, 24, or 32) + let (streaming_sink, stream_handle) = StreamingFlacSink::new(encoder_options.clone(), 16); + tracing::debug!("StreamingFlacSink created"); timer_flac.register(Box::new(streaming_sink)); source_flac.register(Box::new(timer_flac)); @@ -236,8 +237,9 @@ async fn main() -> Result<(), Box> { let mut timer_ogg = TimerNode::with_channel_size(max_lead_time, channel_size); tracing::debug!("TimerNode (OGG) created with {:.1}s max lead time, {} chunk buffer", max_lead_time, channel_size); - let (ogg_sink, ogg_handle) = StreamingOggFlacSink::new(encoder_options, channel_size.min(255) as u8); - tracing::debug!("StreamingOggFlacSink created with {} chunk buffer", channel_size); + // StreamingOggFlacSink doesn't take channel_size - it uses bits_per_sample (16, 24, or 32) + let (ogg_sink, ogg_handle) = StreamingOggFlacSink::new(encoder_options, 16); + tracing::debug!("StreamingOggFlacSink created"); timer_ogg.register(Box::new(ogg_sink)); source_ogg.register(Box::new(timer_ogg));