private void processRequestMtu()

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

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

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

      requestMtuSubject = scopedSubject;
      currentOperation = requestMtuSubject;

      if (bluetoothGatt != null && !bluetoothGatt.requestMtu(mtu)) {
        requestMtuSubject.onError(new PeripheralError(REQUEST_MTU_FAILED, ERROR_STATUS_CALL_FAILED));
      }
    }
  }