bluest 0.6.9

A cross-platform Bluetooth Low Energy (BLE) library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

#![allow(clippy::let_unit_value)]

use bluest::*;
use futures_lite::StreamExt;

fn assert_send<T: Send>(t: T) -> T {
    t
}

async fn check_adapter_apis(adapter: Adapter) -> Result<Device> {
    let events: Result<_> = assert_send(adapter.events()).await;
    let _event: Option<Result<AdapterEvent>> = assert_send(events?.next()).await;
    let _available: Result<()> = assert_send(adapter.wait_available()).await;

    let _devices: Result<Vec<Device>> = assert_send(adapter.connected_devices()).await;
    let devices: Result<Vec<Device>> =
        assert_send(adapter.connected_devices_with_services(&[btuuid::services::GENERIC_ACCESS])).await;

    let scan: Result<_> = assert_send(adapter.scan(&[btuuid::services::GENERIC_ACCESS])).await;
    let _adv: Option<AdvertisingDevice> = assert_send(scan?.next()).await;

    let discovery: Result<_> = assert_send(adapter.discover_devices(&[btuuid::services::GENERIC_ACCESS])).await;
    let _device: Option<Result<Device>> = assert_send(discovery?.next()).await;

    let device: Result<Device> = assert_send(adapter.open_device(&devices?[0].id())).await;

    let device = device?;
    let _res: Result<()> = assert_send(adapter.connect_device(&device)).await;
    let _res: Result<()> = assert_send(adapter.disconnect_device(&device)).await;

    let events: Result<_> = assert_send(adapter.device_connection_events(&device)).await;
    let _event: Option<ConnectionEvent> = assert_send(events?.next()).await;

    Ok(device)
}

async fn check_device_apis(device: Device) -> Result<Service> {
    let _id: DeviceId = device.id();
    let _name: Result<String> = device.name();
    let _name: Result<String> = assert_send(device.name_async()).await;
    let _is_connected: bool = assert_send(device.is_connected()).await;
    let _is_paired: Result<bool> = assert_send(device.is_paired()).await;

    let _pair: Result<()> = assert_send(device.pair()).await;
    let _pair_with_agent: Result<()> = assert_send(device.pair_with_agent(&pairing::NoInputOutputPairingAgent)).await;
    let _unpair: Result<()> = assert_send(device.unpair()).await;

    let _discovery: Result<Vec<Service>> = assert_send(device.discover_services()).await;
    let _discovery: Result<Vec<Service>> =
        assert_send(device.discover_services_with_uuid(btuuid::services::GENERIC_ACCESS)).await;
    let services: Result<Vec<Service>> = assert_send(device.services()).await;

    let _services_changed: Result<()> = assert_send(device.services_changed()).await;

    let _rssi: Result<i16> = assert_send(device.rssi()).await;

    Ok(services?.into_iter().next().unwrap())
}

async fn check_service_apis(service: Service) -> Result<Characteristic> {
    let _uuid: Uuid = service.uuid();
    let _uuid: Result<Uuid> = assert_send(service.uuid_async()).await;
    let _is_primary: Result<bool> = assert_send(service.is_primary()).await;

    let _discovery: Result<Vec<Characteristic>> = assert_send(service.discover_characteristics()).await;
    let _discovery: Result<Vec<Characteristic>> =
        assert_send(service.discover_characteristics_with_uuid(btuuid::characteristics::DEVICE_NAME)).await;
    let characteristics: Result<Vec<Characteristic>> = assert_send(service.characteristics()).await;

    let _discovery: Result<Vec<Service>> = assert_send(service.discover_included_services()).await;
    let _discovery: Result<Vec<Service>> =
        assert_send(service.discover_included_services_with_uuid(btuuid::services::GENERIC_ACCESS)).await;
    let _services: Result<Vec<Service>> = assert_send(service.included_services()).await;

    Ok(characteristics?.into_iter().next().unwrap())
}

async fn check_characteristic_apis(characteristic: Characteristic) -> Result<Descriptor> {
    let _uuid: Uuid = characteristic.uuid();
    let _uuid: Result<Uuid> = assert_send(characteristic.uuid_async()).await;
    let _props: Result<CharacteristicProperties> = assert_send(characteristic.properties()).await;

    let _value: Result<Vec<u8>> = assert_send(characteristic.value()).await;
    let _value: Result<Vec<u8>> = assert_send(characteristic.read()).await;
    let _res: Result<()> = assert_send(characteristic.write(&[0u8])).await;
    let _res: Result<()> = assert_send(characteristic.write_without_response(&[0u8])).await;
    let _len: Result<usize> = assert_send(characteristic.max_write_len_async()).await;

    let notifications: Result<_> = assert_send(characteristic.notify()).await;
    let _notification: Option<Result<Vec<u8>>> = assert_send(notifications?.next()).await;
    let _is_notifying: Result<bool> = assert_send(characteristic.is_notifying()).await;

    let _discovery: Result<Vec<Descriptor>> = assert_send(characteristic.discover_descriptors()).await;
    let descriptors: Result<Vec<Descriptor>> = assert_send(characteristic.descriptors()).await;

    Ok(descriptors?.into_iter().next().unwrap())
}

async fn check_descriptor_apis(descriptor: Descriptor) -> Result<()> {
    let _uuid: Uuid = descriptor.uuid();
    let _uuid: Result<Uuid> = assert_send(descriptor.uuid_async()).await;

    let _value: Result<Vec<u8>> = assert_send(descriptor.value()).await;
    let _value: Result<Vec<u8>> = assert_send(descriptor.read()).await;
    let _res: Result<()> = assert_send(descriptor.write(&[0u8])).await;

    Ok(())
}

#[allow(unused)]
async fn check_apis() -> Result<()> {
    #[cfg(target_os = "android")]
    let adapter: Result<Adapter> = unsafe { Adapter::new(core::ptr::null_mut(), core::ptr::null_mut()) };
    #[cfg(not(target_os = "android"))]
    let adapter: Option<Adapter> = assert_send(Adapter::default()).await;
    let device = check_adapter_apis(adapter.unwrap()).await?;
    let service = check_device_apis(device).await?;
    let characteristic = check_service_apis(service).await?;
    let descriptor = check_characteristic_apis(characteristic).await?;
    check_descriptor_apis(descriptor).await?;

    Ok(())
}

fn main() {}