我有一个包含多个数据的数组需要写入相同的特性,但我想在整个过程完成后收到通知。
我可以通过循环遍历我的数组来完成写操作,如下所示:
byte[][] dataArray = getDataArray();
for (byte[] values: dataArray) {
rxBleConnection.writeCharacteristic(CHARACTERISTIC_UUID, values)
.subscribe(bytes -> {
// here I am notified after each individual write
}, throwable -> {
// handle error per write
});
}
但是,此方法很慢,我无法检测整个写入过程何时完成。有没有办法以某种方式将写入组合在一起,以便我可以监听整个写入事务的完成?
我不能使用Observable.merge
,因为dataArray
可能有一个可变大小和超过9个元素。
有没有办法以某种方式将写入组合在一起,以便我可以监听整个写入事务的完成?
是的,有一种方法。您可以将byte[][]
转换为Observable<byte[]>
,其排放量将在.flatMap()
中处理。然后你只需要等待链的完成。即:
Observable.from(Arrays.asList(getDataArray()))
.flatMap(values -> rxBleConnection.writeCharacteristic(CHARACTERISTIC_UUID, values))
.ignoreElements() // transform to a `Completable` as you are interested only in the completion
.subscribe(
() -> { /* all values have been successfully written */ },
throwable -> { /* an error happened during one of the writes */ }
);