io.micronaut.r2dbc.rxjava2

Interface RxResult

All Superinterfaces:

io.r2dbc.spi.Result

public interface RxResult
extends io.r2dbc.spi.Result

Specialization of Result for RxJava.

Since:

1.0.0

Author:

graemerocher

Method Summary

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.

Method Detail

getRowsUpdated

io.reactivex.Flowable<java.lang.Integer> getRowsUpdated()

Returns the number of rows updated by a query against a database. May be empty if the query did not update any rows.

Specified by:

getRowsUpdated in interface io.r2dbc.spi.Result

Returns:

the number of rows updated by a query against a database

Throws:

java.lang.IllegalStateException - if the result was consumed

map

<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. May be empty if the query did not return any rows. A Row can be only considered valid within a mapping function callback.

Specified by:

map in interface io.r2dbc.spi.Result

Parameters:

mappingFunction - the BiFunction that maps a Row and RowMetadata to a value

Returns:

a mapping of the rows that are the results of a query against a database

Throws:

java.lang.IllegalArgumentException - if mappingFunction is null

java.lang.IllegalStateException - if the result was consumed