Skip to content

Commit 3990383

Browse files
committed
Address PR feedback
1 parent c7c3551 commit 3990383

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

driver/src/main/java/org/neo4j/driver/internal/InternalStatementResult.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -269,12 +269,19 @@ public <T> List<T> list( Function<Record, T> mapFunction )
269269
@Override
270270
public ResultSummary consume()
271271
{
272-
while ( !done )
272+
if ( done )
273273
{
274-
connection.receiveOne();
275274
recordBuffer.clear();
276275
}
277-
recordBuffer.clear();
276+
else
277+
{
278+
do
279+
{
280+
connection.receiveOne();
281+
recordBuffer.clear();
282+
}
283+
while ( !done );
284+
}
278285

279286
return summary;
280287
}

0 commit comments

Comments
 (0)