Блог

Я пытаюсь связаться с CoreBluetooth с помощью Combine, но мой обработчик завершения a PassthroughSubject не вызывается. Ниже вы можете увидеть примерный макет кода. DetailViewModel Содержит периферийное устройство Bluetooth и данные для отправки.

 final class DetailViewModel: NSObject, ObservableObject, CBPeripheralDelegate {
    // Called when the correct write characteristic is found
    private var writeCharacteristicReceived = PassthroughSubject<CBCharacteristic, Never>()
    // Used to send and listen for peripheral data
    private var bluetoothDidChange = PassthroughSubject<Data, Error>()

    func open() -> AnyPublisher<Data, Error> {
        writeCharacteristicReceived.tryMap { characteristic -> AnyPublisher<Data, Error> in
            print("Write char", characteristic)

            let data: Data = try constructPayload()

            self.peripheral?.writeValue(data, for: characteristic, type: .withoutResponse)

            return self.bluetoothDidChange.eraseToAnyPublisher()
        }
        .switchToLatest()
        .eraseToAnyPublisher()
    }

    func peripheral(_ peripheral: CBPeripheral, didUpdateValueFor characteristic: CBCharacteristic, error: Error?) {
        print("Did update value", characteristic.value ?? Data())
        guard let value = characteristic.value, value.count >= 84 else { return }

        defer {
            // Never called
            bluetoothDidChange.send(completion: .finished)
        }

        do {
            let message: Data = try parse(value)
            bluetoothDidChange.send(message)
            // Never called when placed here either
            // bluetoothDidChange.send(completion: .finished)
        } catch {
            bluetoothDidChange.send(completion: .failure(error))
        }
    }
}
 

Затем я прослушиваю эти изменения в самом представлении следующим образом

 viewModel.open().sink(receiveCompletion: { (completion) in
    print("Open completion: (completion)")
}, receiveValue: { (payload) in
    print("Open payload (payload)")
}).store(in: amp;cancellable)
 

Теперь это отлично работает для получения значений время от времени, и блок завершения вызывается правильно при возникновении ошибки. Но я никогда не получаю завершенный обработчик завершения, даже когда я специально это делаю send(completion: .finished) . Кто-нибудь может мне помочь?

Проблема, связанная с writeCharacteristicReceived.send(completion: .finished) тем, что никогда не вызывается. Добавление этого к функции, вызываемой делегатом, решило проблему.

 func peripheral(_ peripheral: CBPeripheral, didDiscoverDescriptorsFor characteristic: CBCharacteristic, error: Error?) {
    if let error = error {
        writeCharacteristicDiscovered.send(completion: .failure(error))
    }
    writeCharacteristicDiscovered.send(characteristic)
    writeCharacteristicDiscovered.send(completion: .finished)
}