Struct Protocol1Client 

pub struct Protocol1Client { /* private fields */ }

Protocol 1 client for connecting to HPSDR hardware.

Implementations

impl Protocol1Client

pub async fn discover(timeout: Duration) -> Result<Vec<DiscoveredDevice>>

Discover all HPSDR devices on the network using Protocol 1.

pub async fn discover_at( addr: Ipv4Addr, timeout: Duration, ) -> Result<Vec<DiscoveredDevice>>

Send a discovery request to a specific address (unicast).

pub async fn connect(device: &DiscoveredDevice) -> Result<Self>

Connect to a discovered Protocol 1 device.

pub async fn start(&mut self) -> Result<()>

Start streaming IQ data from the radio.

pub async fn stop(&mut self) -> Result<()>

Stop streaming.

pub fn set_rx_frequency(&mut self, ddc: usize, freq_hz: u32)

pub fn set_tx_frequency(&mut self, freq_hz: u32)

pub fn set_sample_rate(&mut self, rate: u32)

pub fn set_nddc(&mut self, count: u8)

pub fn tx_drive(&self) -> u8

pub fn set_tx_drive(&mut self, drive: u8)

pub fn set_ptt(&mut self, on: bool)

pub fn set_rx_attenuation(&mut self, db: u8)

pub fn command_sender(&self) -> Sender<P1Command>

Get a sender for runtime commands. The run() loop polls this channel.

pub fn rx_iq_stream(&mut self, ddc: usize) -> Receiver<Vec<Complex<f64>>>

Get a receiver for IQ data from a specific DDC.

pub fn tx_iq_sink(&mut self) -> HeapProd<Complex<f64>>

Get a producer for TX IQ data (lock-free ring buffer, zero-copy).

pub fn status_stream(&mut self) -> Option<Receiver<RadioStatus>>

Get a receiver for radio status updates.

Returns None if already taken (can only be called once).

pub async fn run(&mut self) -> Result<()>

Run the main receive/transmit loop. This blocks until stop() is called or the connection is lost.