Example of how to use the RxCBCentralManager utility

RxCBCentralManagerExample.swift

// Creates the Rx version of the API passing the same parameters as the system version
let centralManager: RxCBCentralManager = RxCBCentralManager(queue: DispatchQueue.main, options: nil)

// Creates a Rx pipe using the published methods
centralManager.scanForPeripherals(withServices: [requiredServiceUIDD], options: nil)
            .filter { (peripheral: CBPeripheral) -> Bool in
                if let name = peripheral.name {
                    return name.contains("peripheralName")
                }
                return false
            }
            .flatMap { (peripheral: CBPeripheral) -> Observable<CBPeripheral> in
                centralManager.stopScan()
                return centralManager.connect(peripheral, options: nil)
            }
            .subscribe(onNext: { peripheral in
                print("Conected to device: \(peripheral.name)")
            }, onError: { error in
                print("Error: \(peripheral.name)")
            })