Publisher setAutoCommit()

in cloud-spanner-r2dbc/src/main/java/com/google/cloud/spanner/r2dbc/v2/DatabaseClientReactiveAdapter.java [193:202]

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

  Publisher<Void> setAutoCommit(boolean autoCommit) {
    return Mono.defer(() -> {
      Mono<Void> result = Mono.empty();
      if (this.autoCommit != autoCommit && this.txnManager.isInTransaction()) {
        // If autocommit is changed, commit the existing transaction.
        result = this.commitTransaction();
      }
      return result.doOnSuccess(empty -> this.autoCommit = autoCommit);
    });
  }