Skip to content

Commit 0ea1fab

Browse files
authored
Cancel DBCommand after finish reading events by PersistenceId (#5311)
1 parent 550a010 commit 0ea1fab

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/contrib/persistence/Akka.Persistence.Sql.Common/Journal/QueryExecutor.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -543,6 +543,7 @@ public virtual async Task SelectByPersistenceIdAsync(DbConnection connection, Ca
543543
var persistent = ReadEvent(reader);
544544
callback(persistent);
545545
}
546+
command.Cancel();
546547
}
547548
}
548549
}

0 commit comments

Comments
 (0)