如何使用RxSwift的RXBluetoothKit将写入特征和特征通知结合起来

import RxSwift
import RxCocoa
import RxBluetoothKit

let centralManager = CentralManager(queue: .main)

centralManager.scanForPeripherals(withServices: nil)
    .subscribe(onNext: { scannedPeripheral in
        // 处理扫描到的外设
    })
    .disposed(by: disposeBag)

centralManager.connect(peripheral)
    .subscribe(onNext: { connectedPeripheral in
        // 处理连接成功的外设
    })
    .disposed(by: disposeBag)

connectedPeripheral.discoverServices(nil)
    .flatMap { services in
        Observable.from(services)
    }
    .flatMap { service in
        service.discoverCharacteristics(nil)
    }
    .subscribe(onNext: { characteristics in
        // 处理发现的特征
    })
    .disposed(by: disposeBag)

let data = Data([0x01, 0x02, 0x03])
let characteristic = // 获取要写入的特征
characteristic.writeValue(data)
    .subscribe(onNext: { _ in
        // 写入成功
    }, onError: { error in
        // 写入失败
    })
    .disposed(by: disposeBag)

characteristic.setNotifyValue(true)
    .flatMap { _ in
        characteristic.observeValueUpdateAndSetNotification()
    }
    .subscribe(onNext: { updatedValue in
        // 处理特征通知的更新值
    })
    .disposed(by: disposeBag)