Module org.neo4j.cypherdsl.core
Interface ReactiveExecutableResultStatement
- All Superinterfaces:
ExecutableStatement
,ReactiveExecutableStatement
This interface extends
ReactiveExecutableStatement
and adds several fetchWithXXX
methods that can be used
with any ResultStatement
to retrieve their results in a reactive fashion.
The same requirements for the needed classes apply as with ReactiveExecutableStatement
.
- Since:
- 2021.2.1
- Author:
- Michael J. Simons
-
Method Summary
Modifier and TypeMethodDescriptiondefault org.reactivestreams.Publisher
<org.neo4j.driver.Record> fetchWith
(org.neo4j.driver.reactivestreams.ReactiveQueryRunner queryRunner) Fetches a publisher of records from a database via the givenqueryRunner
in a reactive fashion.<T> org.reactivestreams.Publisher
<T> fetchWith
(org.neo4j.driver.reactivestreams.ReactiveQueryRunner queryRunner, Function<org.neo4j.driver.Record, T> mappingFunction) Fetches a publisher of things from a database via the givenqueryRunner
in a reactive fashion.Methods inherited from interface org.neo4j.cypherdsl.core.executables.ExecutableStatement
executeWith, executeWith, getCypher, getParameterNames, getParameters
Methods inherited from interface org.neo4j.cypherdsl.core.executables.ReactiveExecutableStatement
executeWith
-
Method Details
-
fetchWith
<T> org.reactivestreams.Publisher<T> fetchWith(org.neo4j.driver.reactivestreams.ReactiveQueryRunner queryRunner, Function<org.neo4j.driver.Record, T> mappingFunction) Fetches a publisher of things from a database via the givenqueryRunner
in a reactive fashion. ThemappingFunction
is used for converting records into a custom types.- Type Parameters:
T
- The type of the returned objects- Parameters:
queryRunner
- Any type of reactive query runner. Neither sessions nor transactions will be closed.mappingFunction
- A mapping function.- Returns:
- A publisher of objects.
-
fetchWith
default org.reactivestreams.Publisher<org.neo4j.driver.Record> fetchWith(org.neo4j.driver.reactivestreams.ReactiveQueryRunner queryRunner) Fetches a publisher of records from a database via the givenqueryRunner
in a reactive fashion.- Parameters:
queryRunner
- Any type of reactive query runner. Neither sessions nor transactions will be closed.- Returns:
- A publisher of records.
-