Struct U3vFrameStream 

pub struct U3vFrameStream { /* private fields */ }

Async frame iterator wrapping blocking USB3 Vision bulk reads.

Internally spawns a blocking reader thread that calls U3vStream::next_frame() in a loop and sends converted Frame values through an mpsc channel. The async consumer reads from the channel via next_frame().

Example

let u3v_stream = device.open_stream(payload_size)?;
let mut frames = U3vFrameStream::start(u3v_stream);
while let Some(frame) = frames.next_frame().await? {
    println!("{}x{} frame", frame.width, frame.height);
}
frames.stop();

Implementations

impl U3vFrameStream

pub fn start<T: UsbTransfer + 'static>(stream: U3vStream<T>) -> Self

Start the frame stream from a configured U3vStream.

The reader thread runs until stop() is called, the U3vStream errors, or the U3vFrameStream is dropped.

pub async fn next_frame(&mut self) -> Result<Option<Frame>, GenicamError>

Receive the next complete frame.

Returns Ok(None) when the stream ends (reader stopped or errored).

pub fn stop(&self)

Signal the reader thread to stop.