BLE Heart Rate Monitor

import SynheartWear

let config = SynheartWearConfig(enabledAdapters: [.bleHrm])
let synheartWear = SynheartWear(config: config)

guard let bleHrm = synheartWear.bleHrm else { return }

// Scan (default timeout 10 s)
let devices = try await bleHrm.scan(timeoutMs: 10000, namePrefix: "Polar")
guard let device = devices.first else { return }

// Connect
try await bleHrm.connect(deviceId: device.deviceId)

// Stream in its own task: onHeartRate doesn't finish on its own
let reader = Task {
    for await sample in bleHrm.onHeartRate {
        print("BPM: \(sample.bpm)")
    }
}

// Disconnect when done
reader.cancel()
try await bleHrm.disconnect()

import ai.synheart.wear.SynheartWear
import ai.synheart.wear.models.DeviceAdapter

val synheartWear = SynheartWear(
    context = this,
    config = SynheartWearConfig(
        enabledAdapters = setOf(DeviceAdapter.BLE_HRM)
    )
)

lifecycleScope.launch {
    synheartWear.initialize()                  // bleHrm is null until this runs
    val bleHrm = synheartWear.bleHrm ?: return@launch

    // Scan (default timeout 10 s)
    val devices = bleHrm.scan(timeoutMs = 10000, namePrefix = "Polar")
    val device = devices.firstOrNull() ?: return@launch

    // Connect
    bleHrm.connect(deviceId = device.deviceId)

    // Collect in its own job: heartRateFlow never completes
    val job = launch {
        bleHrm.heartRateFlow.collect { sample ->
            Log.d(TAG, "BPM: ${sample.bpm}")
        }
    }

    // Disconnect when done
    job.cancel()
    bleHrm.disconnect()
}