Mutiny example is incorrect about r2dbc.github.io HOT 9 CLOSED

Thank you for your contribution. That's merged now. I updated the other samples to use System.out.println(…) via method reference to align the samples.

from r2dbc.github.io.

Thanks for raising an issue. The code on the site does not have a compiled variant as it is a pure Jekyll site. How about submitting a pull request to align the sample with how Mutiny is intended to be used?

from r2dbc.github.io.

Do you have Mutiny bindings or examples somewhere in the code base so I could check out, test and propose something idiomatic?

from r2dbc.github.io.

While R2DBC isn't tied to a particular implementation of Reactive Streams, we have a bit of TCK code at TestKit that requires a concrete Reactive Streams implementation. The MySQL and Postgres drivers allow a quick-start by requiring Docker and Testcontainers. With either one you should be able to give it a spin with Mutiny.

The samples on the website are examples to give users an idea of how the SPI is used in combination with a composition library. The motivation for Uni.createFrom().publisher(…).multi(…) was to illustrate that ConnectionFactory emits a single item that then creates a stream of multiple items (Results).

from r2dbc.github.io.

Noted thanks, I will have a look and get back to you.

from r2dbc.github.io.

@mp911de I see that index.md uses embedded HTML, do you have a quick CLI command to generate the pile of HTML div/span?

The Mutiny snippet should be:

Uni.createFrom().publisher(connectionFactory.create())
  .onItem().transformToMulti(connection -> connection
    .createStatement("SELECT firstname FROM PERSON WHERE age > $1").bind("$1", 42).execute())
  .onItem().transform(result -> result.map((row, rowMetadata) -> row.get("firstname", String.class)))
  .subscribe().with(System.out::println);

from r2dbc.github.io.

Thanks. Formatting the code with http://rouge.jneen.net/v3.25.0/java/ should do the trick.

from r2dbc.github.io.

A quick Ruby script did the job, see #26.

from r2dbc.github.io.

Fixed via #26.

from r2dbc.github.io.