fix: report exhaustion for Stoppable and Skippable

CHANGELOG.md

@@ -39,6 +39,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Fixed `Brownian` and `Red` noise generators to reset after seeking.
 - Fixed sources to correctly handle sample rate and channel count changes at span boundaries.
 - Fixed sources to detect parameter updates after mid-span seeks.
+- Fixed `Stoppable` and `Skippable` not signaling exhaustion.
 
 ## Version [0.22.2] (2026-02-22)
 

src/queue.rs

@@ -350,6 +350,44 @@ mod tests {
         assert_eq!(rx.next(), Some(-10.0));
     }
 
+    #[test]
+    fn sample_rate_correct_after_stopped_source() {
+        let (tx, mut rx) = queue::queue(true);
+
+        let mut stopped_source = SamplesBuffer::new(nz!(1), nz!(48000), vec![0.0; 100]).stoppable();
+        stopped_source.stop();
+
+        let new_source = SamplesBuffer::new(nz!(1), nz!(22050), vec![0.5; 100]);
+        assert_ne!(stopped_source.sample_rate(), new_source.sample_rate());
+        let new_sample_rate = new_source.sample_rate();
+
+        // Pull one sample so keep-alive behavior is triggered.
+        tx.append(stopped_source);
+        let _ = rx.next();
+
+        tx.append(new_source);
+        assert_eq!(rx.sample_rate(), new_sample_rate);
+    }
+
+    #[test]
+    fn sample_rate_correct_after_skipped_source() {
+        let (tx, mut rx) = queue::queue(true);
+
+        let mut skipped_source = SamplesBuffer::new(nz!(1), nz!(48000), vec![0.0; 100]).skippable();
+        crate::source::Skippable::skip(&mut skipped_source);
+
+        let new_source = SamplesBuffer::new(nz!(1), nz!(22050), vec![0.5; 100]);
+        assert_ne!(skipped_source.sample_rate(), new_source.sample_rate());
+        let new_sample_rate = new_source.sample_rate();
+
+        // Pull one sample so keep-alive behavior is triggered.
+        tx.append(skipped_source);
+        let _ = rx.next();
+
+        tx.append(new_source);
+        assert_eq!(rx.sample_rate(), new_sample_rate);
+    }
+
     #[test]
     fn append_updates_metadata() {
         for keep_alive in [false, true] {

src/source/skippable.rs

@@ -84,7 +84,11 @@ where
 {
     #[inline]
     fn current_span_len(&self) -> Option<usize> {
-        self.input.current_span_len()
+        if self.do_skip {
+            Some(0)
+        } else {
+            self.input.current_span_len()
+        }
     }
 
     #[inline]

src/source/stoppable.rs

@@ -74,7 +74,11 @@ where
 {
     #[inline]
     fn current_span_len(&self) -> Option<usize> {
-        self.input.current_span_len()
+        if self.stopped {
+            Some(0)
+        } else {
+            self.input.current_span_len()
+        }
     }
 
     #[inline]