in rx-central-ble/src/main/java/com/uber/rxcentralble/core/CorePeripheralManager.java [88:101]
private void endOperation(PeripheralOperation peripheralOperation) {
synchronized (queueSync) {
operationQueue.remove(peripheralOperation);
if (currentOperation == peripheralOperation) {
currentOperation = null;
if (!operationQueue.isEmpty() && peripheralRelay.getValue() != null) {
currentOperation = operationQueue.remove();
currentOperation.execute(peripheralRelay.getValue());
}
}
}
}