Struct TxStream 

pub struct TxStream { /* private fields */ }

Owned HackRF transmit stream.

start selects TX while the radio is off. write owns the TX transport directly and never changes direction or takes the lifecycle mutex.

Implementations

impl TxStream

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

Start TX while the radio is off.

Returns Error::Busy when RX is active or any control transition is in progress. Calling start on an already-running TX stream succeeds without changing hardware state.

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

Queue normalized complex IQ samples on a started TX stream.

Blocking calls honor timeout; awaited calls use asynchronous USB and ignore it. end_burst appends the terminal zero-filled flush used by libhackrf. If a timeout leaves that flush pending, the next write or stop submits it before accepting a later burst.

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

Flush and drain accepted samples, then turn the radio off.

If the normal 16-transfer TX backpressure window is full, the terminal flush may temporarily submit one additional transfer before draining. This deliberately preserves the requested end-of-burst boundary.

A successful stop leaves the stream reusable. After a stream I/O failure, stop still attempts to turn the radio off and permanently invalidates this stream. If draining the endpoint fails, reopen the device before transmitting again because its pending transfers cannot be safely reused.

Trait Implementations

impl Drop for TxStream

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.