in cloud-spanner-r2dbc-samples/cloud-spanner-r2dbc-sample/src/main/java/com/example/BookExampleApp.java [119:128]
public void retrieveBooks() {
Flux.from(this.connection.createStatement("SELECT * FROM books").execute())
.flatMap(
spannerResult ->
spannerResult.map(
(Row r, RowMetadata meta) -> describeBook(r)))
.doOnNext(System.out::println)
.collectList()
.block();
}