in rx-central-ble/src/main/java/com/uber/rxcentralble/core/CorePeripheralManager.java [42:52]
public void setPeripheral(Peripheral peripheral) {
peripheralRelay.accept(peripheral);
synchronized (queueSync) {
if (!operationQueue.isEmpty() && currentOperation == null) {
currentOperation = operationQueue.remove();
currentOperation.execute(peripheralRelay.getValue());
}
}
}