private void endOperation()

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());
        }
      }
    }
  }