private void processReadRssi()

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

• 14 lines of code
• 4 McCabe index (conditional complexity)

  private void processReadRssi(SingleSubject<Integer> scopedSubject) {
    synchronized (syncRoot) {
      PeripheralError error = subscribeChecks();
      if (error != null) {
        scopedSubject.onError(error);
        return;
      }

      readRssiSubject = scopedSubject;
      currentOperation = readRssiSubject;

      if (bluetoothGatt != null && !bluetoothGatt.readRemoteRssi()) {
        readRssiSubject.onError(new PeripheralError(READ_RSSI_FAILED, ERROR_STATUS_CALL_FAILED));
      }
    }
  }