diff --git a/neo4j-utils/src/main/java/uk/ac/rothamsted/neo4j/utils/Neo4jUtils.java b/neo4j-utils/src/main/java/uk/ac/rothamsted/neo4j/utils/Neo4jUtils.java index 4b23c2c..dcab12d 100644 --- a/neo4j-utils/src/main/java/uk/ac/rothamsted/neo4j/utils/Neo4jUtils.java +++ b/neo4j-utils/src/main/java/uk/ac/rothamsted/neo4j/utils/Neo4jUtils.java @@ -41,9 +41,8 @@ private Neo4jUtils () {} /** * Helper to process a Neo4j read query in a reactive style. * - * In a nutshell, prepares a {@link Flux} that pushes an R object for each record - * returned by the query in the callback. Records are mapped to R by the recordMapper - * function. + * In a nutshell, prepares a {@link Flux} that publishes each record + * returned by the query in the callback. * * This is a template based on the approach described * @@ -118,7 +117,7 @@ public static Iterator paginatedRead ( BiFunction> pageSelector = offset -> { - Iterator pageItr = reactiveRead ( tx -> callBack.apply ( tx, offset), neoDriver ) + Iterator pageItr = reactiveRead ( tx -> callBack.apply (tx, offset), neoDriver ) .toIterable () .iterator ();