public RequestMtu()

in rx-central-ble/src/main/java/com/uber/rxcentralble/core/operations/RequestMtu.java [37:49]

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

  public RequestMtu(int requestedMtu, int timeoutMs) {
    resultSingle =
        peripheralRelay
            .filter(Optional::isPresent)
            .map(Optional::get)
            .firstOrError()
            .doOnSuccess(g -> peripheralRelay.accept(Optional.empty()))
            .flatMap(peripheral -> peripheral.requestMtu(requestedMtu))
            .toObservable()
            .share()
            .firstOrError()
            .timeout(timeoutMs, TimeUnit.MILLISECONDS);
  }