Skip to content

Commit

Permalink
Very minor cleaning.
Browse files Browse the repository at this point in the history
  • Loading branch information
marco-brandizi committed Oct 10, 2024
1 parent 713b96a commit 5f64e36
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
*
Expand Down Expand Up @@ -118,7 +117,7 @@ public static Iterator<Record> paginatedRead ( BiFunction<ReactiveTransactionCon
// or null when the current page has not elements anymore.
Function<Long, Iterator<Record>> pageSelector = offset ->
{
Iterator<Record> pageItr = reactiveRead ( tx -> callBack.apply ( tx, offset), neoDriver )
Iterator<Record> pageItr = reactiveRead ( tx -> callBack.apply (tx, offset), neoDriver )
.toIterable ()
.iterator ();

Expand Down

0 comments on commit 5f64e36

Please sign in to comment.