public void disconnect()

in rx-central-ble/src/main/java/com/uber/rxcentralble/core/CorePeripheral.java [200:219]

• 17 lines of code
• 6 McCabe index (conditional complexity)

  public void disconnect() {
    synchronized (syncRoot) {
      if (bluetoothGatt != null) {
        bluetoothGatt.disconnect();
        bluetoothGatt = null;
      }

      connectedRelay.accept(false);

      if (connectionStateSubject != null && connectionStateSubject.hasObservers()) {
        connectionStateSubject.onError(new ConnectionError(DISCONNECTION));
        connectionStateSubject = null;
      }

      if (currentOperation != null && currentOperation.hasObservers()) {
        currentOperation.onError(new ConnectionError(DISCONNECTION));
        currentOperation = null;
      }
    }
  }