Method wait_for_sample

rustcv-backend-msmf/src/stream.rs:526–535

Waits for a sample to become available and returns it. Uses a semaphore to track available frames. The semaphore's permits accumulate when frames arrive, ensuring no notifications are missed.

(&self)

    /// Uses a semaphore to track available frames. The semaphore's permits
    /// accumulate when frames arrive, ensuring no notifications are missed.
    async fn wait_for_sample(&self) -> Result<SendableSample> {
        let permit = self.shared.frame_ready.acquire().await.map_err(|e| {
            CameraError::Io(std::io::Error::other(format!("Semaphore error: {}", e)))
        })?;
        permit.forget();

        let mut slot = self.shared.sample_slot.lock().unwrap();
        slot.take()
            .ok_or_else(|| CameraError::Io(std::io::Error::other("Frame slot was empty")))
    }
}