Fix callable nullness

Author: abnegate

src/Database/Database.php

@@ -3533,8 +3533,7 @@ public function createDocuments(
                 if ($this->resolveRelationships) {
                     $document = $this->silent(fn () => $this->populateDocumentRelationships($collection, $document));
                 }
-
-                $onNext($document);
+                $onNext && $onNext($document);
                 $modified++;
             }
         }
@@ -4230,7 +4229,7 @@ public function updateDocuments(
                     $this->purgeCachedDocument($collection->getId(), $document->getId());
                 }
 
-                $onNext($document);
+                $onNext && $onNext($document);
                 $modified++;
             }
 
@@ -4809,7 +4808,7 @@ public function createOrUpdateDocumentsWithIncrease(
                     $this->purgeCachedDocument($collection->getId(), $document->getId());
                 }
 
-                $onNext($document);
+                $onNext && $onNext($document);
                 $modified++;
             }
         }
@@ -5594,7 +5593,7 @@ public function deleteDocuments(
                     $this->purgeCachedDocument($collection->getId(), $document->getId());
                 }
 
-                $onNext($document);
+                $onNext && $onNext($document);
                 $modified++;
             }
 

src/Database/Mirror.php

@@ -561,7 +561,7 @@ public function createDocuments(
             $documents,
             $batchSize,
             function ($doc) use ($onNext, &$modified) {
-                $onNext($doc);
+                $onNext && $onNext($doc);
                 $modified++;
             },
         );
@@ -575,10 +575,6 @@ function ($doc) use ($onNext, &$modified) {
 
         $upgrade = $this->silent(fn () => $this->getUpgradeStatus($collection));
         if ($upgrade === null || $upgrade->getAttribute('status', '') !== 'upgraded') {
-            foreach ($documents as $document) {
-                $onNext($document);
-            }
-
             return $modified;
         }
 
@@ -690,7 +686,7 @@ public function updateDocuments(
             $queries,
             $batchSize,
             function ($doc) use ($onNext, &$modified) {
-                $onNext($doc);
+                $onNext && $onNext($doc);
                 $modified++;
             }
         );
@@ -803,7 +799,7 @@ public function deleteDocuments(
             $queries,
             $batchSize,
             function ($doc) use (&$modified, $onNext) {
-                $onNext($doc);
+                $onNext && $onNext($doc);
                 $modified++;
             },
         );