Struct BluestConnection 

pub struct BluestConnection { /* private fields */ }

A GattConnection over a connected bluest Device that reconnects and retries on a dropped link.

Implementations

impl BluestConnection

pub async fn new(adapter: Adapter, device: Device) -> Result<Self>

Wrap an already-connected device, discovering its services and characteristics.

Errors

Returns BleError::Backend on a bluest discovery failure.

Trait Implementations

impl AdvertSource for BluestConnection

fn watch_adverts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Receiver<RawAdvert>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream Apple HAP advertisements by running a continuous adapter scan.

Spawns a background task that feeds every Apple (company id 0x004C) manufacturer-data frame into the returned channel. Forwarding is best-effort: frames are dropped when the receiver falls behind, not queued unboundedly, to ensure the task never blocks on backpressure and can always respond to a pause request. While a connect owns the radio (the ScanGate is paused) the task drops its scan stream and restarts it on resume. The task stops for good when the receiver is dropped or the adapter’s scan stream ends.

Intended for a single active watcher per connection: concurrent scan tasks would share one scanning flag and corrupt the pause-ack protocol.

Errors

Returns crate::error::BleError on adapter/scan failures.

impl GattConnection for BluestConnection

fn instance_id<'life0, 'life1, 'async_trait>( &'life0 self, char_uuid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u16>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read one characteristic’s HAP instance id (its Instance-ID descriptor) without walking the whole tree — used to address the pairing characteristics before the (slow) full database sweep.

fn max_write<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The maximum bytes that fit in a single GATT write — the HAP-BLE PDU fragment size. Backends that can’t determine the negotiated MTU return a conservative default.

fn generation<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

A monotonically increasing link-generation counter that advances on every reconnect. A secure session minted at generation g is invalidated when the accessory drops the link (the count moves past g), so the holder must re-run Pair Verify before its next encrypted operation. Backends without a reconnect supervisor never invalidate sessions and return 0.

fn write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, char_uuid: &'life1 str, value: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write a value to a characteristic identified by its UUID.

fn read<'life0, 'life1, 'async_trait>( &'life0 self, char_uuid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read a characteristic’s current value by UUID.

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, char_uuid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Receiver<Vec<u8>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribe to notifications on a characteristic; the receiver yields raw notification payloads.

fn enumerate<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<GattService>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Enumerate the accessory’s services and characteristics (with iids).

fn disconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Release the active link. A sleepy HAP accessory only advertises and emits encrypted broadcasts while disconnected, so a caller watching for sleepy events must disconnect after setup. Default no-op for backends and mocks with no live link.