using System.Collections.Generic; using System.Data.Common; using Dapper; namespace PluralKit.Core { public static class ConnectionUtils { public static async IAsyncEnumerable QueryStreamAsync(this IPKConnection conn, string sql, object param) { await using var reader = (DbDataReader)await conn.ExecuteReaderAsync(sql, param); var parser = reader.GetRowParser(); while (await reader.ReadAsync()) yield return parser(reader); } } }