Flux runSelectStatement()

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

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

  Flux<SpannerClientLibraryRow> runSelectStatement(Statement statement) {
    return Flux.create(
        sink -> {
          if (this.txnManager.isInReadWriteTransaction()) {
            this.txnManager.runInTransaction(ctx -> runSelectStatementAsFlux(ctx, statement, sink));
          } else {
            runSelectStatementAsFlux(this.txnManager.getReadContext(), statement, sink);
          }
        });
  }