public interface RxResult
extends io.r2dbc.spi.Result
Modifier and Type | Method and Description |
---|---|
io.reactivex.Flowable<java.lang.Integer> |
getRowsUpdated()
Returns the number of rows updated by a query against a database.
|
<T> io.reactivex.Flowable<T> |
map(java.util.function.BiFunction<io.r2dbc.spi.Row,io.r2dbc.spi.RowMetadata,? extends T> mappingFunction)
Returns a mapping of the rows that are the results of a query against a database.
|
io.reactivex.Flowable<java.lang.Integer> getRowsUpdated()
getRowsUpdated
in interface io.r2dbc.spi.Result
java.lang.IllegalStateException
- if the result was consumed<T> io.reactivex.Flowable<T> map(java.util.function.BiFunction<io.r2dbc.spi.Row,io.r2dbc.spi.RowMetadata,? extends T> mappingFunction)
Row
can be only considered valid within a
mapping function
callback.map
in interface io.r2dbc.spi.Result
mappingFunction
- the BiFunction
that maps a Row
and RowMetadata
to a valuejava.lang.IllegalArgumentException
- if mappingFunction
is null
java.lang.IllegalStateException
- if the result was consumed