corebluetooth-async 0.1.0

An asynchronous wrapper for the `corebluetooth` crate
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

# corebluetooth-async

An asynchronous wrapper for the `corebluetooth` crate.

This crate provides `async` functions and streams for interacting with the CoreBluetooth
framework, making it easy to use within `async` Rust applications. It is built on top of the
[`corebluetooth`](../corebluetooth) crate. This is likely the crate you will want to use for most
applications.

## Example

This example shows how to scan for peripherals and print their advertisement data using an
asynchronous stream.

Add `futures` and `tokio` (or another async runtime) to your `Cargo.toml` dependencies. You will
also need to depend on the `corebluetooth` crate to have access to some enums.

```rust,no_run
use corebluetooth::CBManagerState;
use corebluetooth_async::CentralManagerAsync;
use dispatch_executor::MainThreadMarker;
use futures::StreamExt;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mtm = MainThreadMarker::new().unwrap();
    let central = CentralManagerAsync::main_thread(false, mtm);

    // Wait for the manager to power on.
    central
        .state_updates()
        .filter(|&state| state == CBManagerState::PoweredOn)
        .next()
        .await;

    println!("Bluetooth is powered on, starting scan.");

    // Start scanning for peripherals.
    let mut discoveries = central.scan(None, false, None);

    // Print discoveries as they come in.
    while let Some(discovery) = discoveries.next().await {
        if let Some(name) = discovery.peripheral.name() {
            println!(
                "Discovered peripheral '{}' (RSSI: {}) with advertisement data: {:?}",
                name, discovery.rssi, discovery.advertisement_data
            );
        }
    }

    Ok(())
}
```