private CompletableSubject getErrorSubject()

in rx-central-ble/src/main/java/com/uber/rxcentralble/core/scanners/ThrottledLollipopScanner.java [205:213]

• 8 lines of code
• 2 McCabe index (conditional complexity)

  private CompletableSubject getErrorSubject() {
    synchronized (syncRoot) {
      if (errorSubject.hasThrowable()) {
        errorSubject = CompletableSubject.create();
      }

      return errorSubject;
    }
  }