public Publisher create()

in cloud-spanner-r2dbc/src/main/java/com/google/cloud/spanner/r2dbc/v2/SpannerClientLibraryConnectionFactory.java [48:64]

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

  public Publisher<? extends Connection> create() {
    Mono<SpannerClientLibraryConnection> connection = Mono.just(
        new SpannerClientLibraryConnection(
            new DatabaseClientReactiveAdapter(this.spannerClient, this.config))
    );

    if (this.config.isReadonly()) {
      connection = connection.delayUntil(conn -> conn.beginReadonlyTransaction());
    }

    // Autocommit is on by default; turn off if needed.
    if (!this.config.isAutocommit()) {
      connection = connection.delayUntil(conn -> conn.setAutoCommit(false));
    }

    return connection;
  }