Struct soapysdr::RxStream

pub struct RxStream<E: StreamSample> { /* private fields */ }

A stream open for receiving.

To obtain a RxStream, call Device::rx_stream. The type parameter E represents the type of this stream’s samples.

Streams may involve multiple channels.

Implementations

impl<E: StreamSample> RxStream<E>

pub fn mtu(&self) -> Result<usize, Error>

Get the stream’s maximum transmission unit (MTU) in number of elements.

The MTU specifies the maximum payload transfer in a stream operation. This value can be used as a stream buffer allocation size that can best optimize throughput given the underlying stream implementation.

pub fn activate(&mut self, time_ns: Option<i64>) -> Result<(), Error>

Activate a stream.

Call activate to enable a stream before using read()

Arguments:

• time_ns – optional activation time in nanoseconds

pub fn active(&self) -> bool

Fetch the active state of the stream.

pub fn deactivate(&mut self, time_ns: Option<i64>) -> Result<(), Error>

Deactivate a stream. The implementation will control switches or halt data flow.

Arguments:

• time_ns – optional deactivation time in nanoseconds

pub fn read( &mut self, buffers: &mut [&mut [E]], timeout_us: i64, ) -> Result<usize, Error>

Read samples from the stream into the provided buffers.

buffers contains one destination slice for each channel of this stream.

Returns the number of samples read, which may be smaller than the size of the passed arrays.

Panics

• If buffers is not the same length as the channels array passed to Device::rx_stream.

Trait Implementations

impl<E: StreamSample> Drop for RxStream<E>

fn drop(&mut self)

Executes the destructor for this type.

impl<E: StreamSample> Send for RxStream<E>

Streams may only be used on one thread at a time but may be sent between threads