diff --git a/src/Source/DoctrineODMQuerySourceIterator.php b/src/Source/DoctrineODMQuerySourceIterator.php index 520e13d7..c9b32696 100644 --- a/src/Source/DoctrineODMQuerySourceIterator.php +++ b/src/Source/DoctrineODMQuerySourceIterator.php @@ -36,7 +36,11 @@ public function current() { $current = $this->iterator->current(); - return $this->getCurrentData($current[0]); + $data = $this->getCurrentData($current[0]); + + $this->query->getDocumentManager()->clear(); + + return $data; } public function rewind(): void diff --git a/src/Source/DoctrineORMQuerySourceIterator.php b/src/Source/DoctrineORMQuerySourceIterator.php index b81cec9e..25b3f23c 100644 --- a/src/Source/DoctrineORMQuerySourceIterator.php +++ b/src/Source/DoctrineORMQuerySourceIterator.php @@ -43,7 +43,11 @@ public function current() { $current = $this->iterator->current(); - return $this->getCurrentData($current[0]); + $data = $this->getCurrentData($current[0]); + + $this->query->getEntityManager()->clear(); + + return $data; } final public function rewind(): void