rxAndroidBle bekommen lange Antwort schreiben

Question

Ich mache eine lange schreiben zu einem BLE für ein OTA-Update, aber ich muss auf die Schreibantwort des BLE-Geräts für das Senden von mehr Daten warten, aber ich weiß nicht, wie zu fangen die Vorrichtung zum schreiben einer Antwort, ich bin mit einem Samsung galaxy tab s2 mit android 7 und Kotlin für meinen Code

override fun otaDataWrite(data:ByteArray) { 
    manager.connection?.flatMap { rxBleConnection: RxBleConnection? -> rxBleConnection?.createNewLongWriteBuilder() 
      ?.setCharacteristicUuid(OTACharacteristics.OTA_DATA.uuid) 
      ?.setBytes(data) 
      ?.setMaxBatchSize(totalPackages) 
      ?.build() 
    }?.subscribe({ t: ByteArray? -> 
     Log.i("arrive", "data ${converter.bytesToHex(t)}") 
     manageOtaWrite() 
    }, { t: Throwable? -> t?.printStackTrace() }) 

jedes Mal, wenn ich die Eigenschaft, schreiben die Abonnements reagieren mich sofort mit den geschriebenen Daten, ich brauche capture die Antwort des Merkmals, um mehr Daten zu senden

Answer 1

Sie schreiben über die Antwort aus dem Merkmal - ich nehme an, dass das Merkmal ref er ist derjenige mit UUID=OTA_DATA. Das Long Write besteht aus kleinen internen Schreibvorgängen (sogenannten Batches).

Was Sie wahrscheinlich erreichen wollen, ist so etwas wie:

fun otaDataWrite(data: ByteArray) { 
    manager.connection!!.setupNotification(OTA_DATA) // first we need to get the notification on to get the response 
      .flatMap { responseNotificationObservable -> // when the notification is ready we create the long write 
       connection.createNewLongWriteBuilder() 
         .setCharacteristicUuid(OTA_DATA) 
         .setBytes(data) 
//      .setMaxBatchSize() // -> if omitted will default to the MTU (20 bytes if MTU was not changed). Should be used only if a single write should be less than MTU in size 
         .setWriteOperationAckStrategy { writeCompletedObservable -> // we need to postpone writing of the next batch of data till we get the response notification 
          Observable.zip(// so we zip the response notification 
            responseNotificationObservable, 
            writeCompletedObservable, // with the acknowledgement of the written batch 
            { _, writeCompletedBoolean -> writeCompletedBoolean } // when both are available the next batch will be written 
          ) 
         } 
         .build() 
      } 
      .take(1) // with this line the notification that was set above will be discarded after the long write will finish 
      .subscribe(
        { byteArray -> 
         Log.i("arrive", "data ${converter.bytesToHex(byteArray)}") 
         manageOtaWrite() 
        }, 
        { it.printStackTrace() } 
      ) 
}