public Completable registerNotification()

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

• 9 lines of code
• 1 McCabe index (conditional complexity)

  public Completable registerNotification(UUID svc, UUID chr, @Nullable Preprocessor preprocessor) {
    final SingleSubject<UUID> scopedSubject = SingleSubject.create();

    return scopedSubject
        .filter(regChr -> regChr.equals(chr))
        .ignoreElement()
        .doOnSubscribe(
            disposable -> processRegisterNotification(scopedSubject, svc, chr, preprocessor))
        .doFinally(() -> clearRegisterNotificationSubject(scopedSubject));
  }