Method next_frame

rustcv-backend-v4l2/src/stream.rs:66–103

(&mut self)

    }

    async fn next_frame(&mut self) -> Result<Frame<'_>> {
        if !self.is_streaming {
            return Err(CameraError::Io(io::Error::other("Stream not started")));
        }

        // 调用 CaptureStream 的 next
        let (buf, meta) = self.inner.next().map_err(CameraError::Io)?;
        let arrival_time = Instant::now();

        let hw_ns =
            (meta.timestamp.sec as u64 * 1_000_000_000) + (meta.timestamp.usec as u64 * 1_000);

        let synced_time = self.clock_sync.correct(hw_ns, arrival_time);

        let metadata = FrameMetadata {
            actual_exposure_us: None,
            actual_gain_db: None,
            trigger_fired: false,
            strobe_active: false,
        };

        let frame = Frame {
            data: buf,
            width: self.format.width,
            height: self.format.height,
            stride: meta.bytesused as usize / self.format.height as usize,
            format: crate::pixel_map::from_v4l_fourcc(self.format.fourcc),
            sequence: meta.sequence as u64,
            timestamp: Timestamp {
                hw_raw_ns: hw_ns,
                system_synced: synced_time,
            },
            metadata,
            backend_handle: &V4L2_HANDLE_INSTANCE,
        };

        Ok(frame)
    }

    #[cfg(feature = "simulation")]
    async fn inject_frame(&mut self, _frame: Frame<'_>) -> Result<()> {