public Single requestMtu()

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

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

  public Single<Integer> requestMtu(int mtu) {
    if (Build.VERSION.SDK_INT < Build.VERSION_CODES.LOLLIPOP) {
      return Single.error(new PeripheralError(PeripheralError.Code.MINIMUM_SDK_UNSUPPORTED));
    }

    final SingleSubject<Integer> scopedSubject = SingleSubject.create();

    return scopedSubject
        .doOnSubscribe(disposable -> processRequestMtu(scopedSubject, mtu))
        .doFinally(() -> clearRequestMtuSubject(scopedSubject));
  }