func write()

in Sources/RxCBCentral/core/Operations/Write.swift [50:64]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    func write(service: CBUUID, characteristic: CBUUID, data: Data) -> Single<RxPeripheral> {
        return _peripheralSubject
            .flatMap({ (rxPeripheral) -> Observable<RxPeripheral> in
                var chunkCompletables: [Completable] = []
                let byteArray = [UInt8](data)
                
                byteArray.forEachChunk(by: rxPeripheral.maxWriteLength) { chunk in
                    chunkCompletables.append(rxPeripheral.write(service: service, characteristic: characteristic, data: Data(chunk)))
                }
                
                return Completable.concat(chunkCompletables).andThen(Observable.just(rxPeripheral))
            })
            .take(1)
            .asSingle()
    }