@FunctionalInterface public interface ExecuteFunction
Statement for a (delayed)
Result stream.
Note that discarded Result objects must be consumed according
to the R2DBC spec via either Result.getRowsUpdated() or
Result.map(BiFunction).
Typically, implementations invoke the Statement.execute() method
to initiate execution of the statement object.
For example:
DatabaseClient.builder()
.executeFunction(statement -> statement.execute())
.build();
Statement.execute()| Modifier and Type | Method and Description |
|---|---|
org.reactivestreams.Publisher<? extends io.r2dbc.spi.Result> |
execute(io.r2dbc.spi.Statement statement)
Execute the given
Statement for a stream of Result objects. |