Dispose of current result when next result is requested

amphp · Sep 1, 2023 · a267853 · a267853
1 parent 8a7d4ac
commit a267853
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/Internal/MysqlConnectionResult.php b/src/Internal/MysqlConnectionResult.php
@@ -72,9 +72,7 @@ public function fetchRow(): ?array
 
  public function getNextResult(): ?MysqlResult
  {
- if ($this->generator->valid()) {
- throw new \Error('Consume entire current result before requesting next result');
- }
+ self::dispose($this->generator);
 
  $this->nextResult ??= async(function (): ?MysqlResult {
  $deferred = $this->result->next ??= new DeferredFuture;