Struct BluerConnection 

pub struct BluerConnection { /* private fields */ }

BlueZ connection wrapper

Wraps a bluer::Device with connection state tracking and write queue. BLE only allows one pending write per connection, so all writes are serialized through the write queue.

Implementations

impl BluerConnection

pub async fn discover_mtu( &self, service_uuid: Uuid, char_uuid: Uuid, ) -> Result<u16>

Discover the actual negotiated MTU via a characteristic

BlueZ negotiates MTU during the first GATT operation. Call this after connecting to get the actual negotiated value. Uses AcquireWrite which returns the negotiated MTU.

pub fn device(&self) -> &Device

Get the underlying BlueZ device

pub async fn update_rssi(&self)

Update RSSI from device

pub async fn set_mtu(&self, mtu: u16)

Update MTU

pub async fn set_phy(&self, phy: BlePhy)

Update PHY

pub async fn mark_dead(&self)

Mark connection as dead

pub async fn disconnect(&self) -> Result<()>

Disconnect from the device

Clears any pending writes and disconnects the BLE connection.

pub async fn discover_services(&self) -> Result<()>

Discover GATT services

pub async fn services(&self) -> Result<Vec<Service>>

Get GATT services

pub async fn find_service(&self, uuid: Uuid) -> Result<Option<Service>>

Find a service by UUID

pub async fn read_characteristic( &self, service_uuid: Uuid, char_uuid: Uuid, ) -> Result<Vec<u8>>

Read a characteristic value

pub async fn write_characteristic( &self, service_uuid: Uuid, char_uuid: Uuid, value: &[u8], ) -> Result<()>

Write a characteristic value (direct, non-queued)

Warning: BLE only allows one pending write per connection. Calling this method concurrently may cause write failures. Use write_characteristic_queued for safe concurrent writes.

pub async fn write_characteristic_queued( &self, service_uuid: Uuid, char_uuid: Uuid, value: &[u8], ) -> Result<()>

Write a characteristic value with queuing

BLE only allows one pending write per connection. This method queues writes and processes them serially, preventing write conflicts. Safe to call concurrently from multiple tasks.

Returns when the write completes (or fails).

pub async fn write_queue_depth(&self) -> usize

Get the current write queue depth

Useful for monitoring backpressure. If the queue grows too large, consider slowing down write requests.

pub async fn write_in_progress(&self) -> bool

Check if a write is currently in progress

pub async fn clear_write_queue(&self)

Clear the write queue (e.g., on disconnect)

All pending writes will receive an error.

pub async fn subscribe_characteristic( &self, service_uuid: Uuid, char_uuid: Uuid, ) -> Result<impl Stream<Item = Vec<u8>>>

Subscribe to characteristic notifications

Trait Implementations

impl BleConnection for BluerConnection

fn peer_id(&self) -> &NodeId

Get the remote peer’s node ID

fn is_alive(&self) -> bool

Check if connection is still alive

fn mtu(&self) -> u16

Get the negotiated MTU

fn phy(&self) -> BlePhy

Get the current PHY

fn rssi(&self) -> Option<i8>

Get RSSI (signal strength) in dBm

fn connected_duration(&self) -> Duration

Get connection duration

impl Clone for BluerConnection

fn clone(&self) -> BluerConnection

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.