rx-central-ble/src/main/java/com/uber/rxcentralble/core/operations/ReadRssi.java [42:61]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            .toObservable()
            .share()
            .firstOrError()
            .timeout(timeoutMs, TimeUnit.MILLISECONDS);
  }

  @Override
  public final Single<Integer> result() {
    return resultSingle;
  }

  @Override
  public void execute(Peripheral peripheral) {
    peripheralRelay.accept(Optional.of(peripheral));
  }

  @Override
  public Single<Integer> executeWithResult(Peripheral peripheral) {
    return resultSingle
            .doOnSubscribe(disposable -> execute(peripheral));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



rx-central-ble/src/main/java/com/uber/rxcentralble/core/operations/RequestMtu.java [45:64]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            .toObservable()
            .share()
            .firstOrError()
            .timeout(timeoutMs, TimeUnit.MILLISECONDS);
  }

  @Override
  public final Single<Integer> result() {
    return resultSingle;
  }

  @Override
  public void execute(Peripheral peripheral) {
    peripheralRelay.accept(Optional.of(peripheral));
  }

  @Override
  public Single<Integer> executeWithResult(Peripheral peripheral) {
    return resultSingle
            .doOnSubscribe(disposable -> execute(peripheral));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -