Struct RxStream 

pub struct RxStream { /* private fields */ }

Owned HackRF receive stream.

Waiting the first RxStream::start chooses native blocking USB; awaiting it chooses asynchronous USB. Do not mix the two execution styles on one stream. The steady-state read path owns its endpoint and never takes the device lifecycle mutex.

Implementations

impl RxStream

pub fn start(&mut self) -> impl MaybeFuture<Output = Result<()>> + '_

Start reception and the persistent USB transfer queue.

pub fn read<'a>( &'a mut self, out: &'a mut [Complex32], timeout: Option<Duration>, ) -> impl MaybeFuture<Output = Result<usize>> + 'a

Read normalized complex IQ samples.

Blocking operation fills the output until its total timeout expires; None waits indefinitely. Awaited operation ignores the timeout and consumes buffered data or one new USB completion.

pub fn stop(&mut self) -> impl MaybeFuture<Output = Result<StreamingStats>> + '_

Stop reception and return accumulated stream counters.

Trait Implementations

impl Drop for RxStream

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.