Replace Task<IEnumerable> with IAsyncEnumerable

Author: Joy-less

SQLiteSharp/SQLiteConnection.cs

@@ -162,8 +162,8 @@ public IEnumerable<TableInfo> GetTables(string? tableName = null) {
         return CreateCommand(query).ExecuteQuery(GetTablePlaceholder<TableInfo>("table_list"));
     }
     /// <inheritdoc cref="GetTables(string?)"/>
-    public Task<IEnumerable<TableInfo>> GetTablesAsync(string? tableName = null) {
-        return Task.Run(() => GetTables(tableName));
+    public IAsyncEnumerable<TableInfo> GetTablesAsync(string? tableName = null) {
+        return GetTables(tableName).ToAsyncEnumerable();
     }
 
     /// <summary>
@@ -174,8 +174,8 @@ public IEnumerable<ColumnInfo> GetColumns(string tableName) {
         return CreateCommand(query).ExecuteQuery(GetTablePlaceholder<ColumnInfo>("table_info"));
     }
     /// <inheritdoc cref="GetColumns(string)"/>
-    public Task<IEnumerable<ColumnInfo>> GetColumnsAsync(string tableName) {
-        return Task.Run(() => GetColumns(tableName));
+    public IAsyncEnumerable<ColumnInfo> GetColumnsAsync(string tableName) {
+        return GetColumns(tableName).ToAsyncEnumerable();
     }
 
     /// <summary>
@@ -240,8 +240,8 @@ public IEnumerable<T> ExecuteScalars<T>(string query, params IEnumerable<object?
         return command.ExecuteScalars<T>();
     }
     /// <inheritdoc cref="ExecuteScalars{T}(string, IEnumerable{object?})"/>
-    public Task<IEnumerable<T>> ExecuteScalarsAsync<T>(string query, params IEnumerable<object?> parameters) {
-        return Task.Run(() => ExecuteScalars<T>(query, parameters));
+    public IAsyncEnumerable<T> ExecuteScalarsAsync<T>(string query, params IEnumerable<object?> parameters) {
+        return ExecuteScalars<T>(query, parameters).ToAsyncEnumerable();
     }
 
     /// <inheritdoc cref="ExecuteScalars{T}(string, IEnumerable{object?})"/>
@@ -250,8 +250,8 @@ public IEnumerable<T> ExecuteScalars<T>(string query, IReadOnlyDictionary<string
         return command.ExecuteScalars<T>();
     }
     /// <inheritdoc cref="ExecuteScalars{T}(string, IReadOnlyDictionary{string, object?})"/>
-    public Task<IEnumerable<T>> ExecuteScalarsAsync<T>(string query, IReadOnlyDictionary<string, object?> parameters) {
-        return Task.Run(() => ExecuteScalars<T>(query, parameters));
+    public IAsyncEnumerable<T> ExecuteScalarsAsync<T>(string query, IReadOnlyDictionary<string, object?> parameters) {
+        return ExecuteScalars<T>(query, parameters).ToAsyncEnumerable();
     }
 
     /// <summary>

SQLiteSharp/SqlBuilder.cs

@@ -246,7 +246,7 @@ public IEnumerable<TScalar> ExecuteScalars<TScalar>() {
         return Table.Connection.ExecuteScalars<TScalar>(GetCommand(), Parameters);
     }
     /// <inheritdoc cref="SqliteConnection.ExecuteScalarsAsync{T}(string, IReadOnlyDictionary{string, object?})"/>
-    public Task<IEnumerable<TScalar>> ExecuteScalarsAsync<TScalar>() {
+    public IAsyncEnumerable<TScalar> ExecuteScalarsAsync<TScalar>() {
         return Table.Connection.ExecuteScalarsAsync<TScalar>(GetCommand(), Parameters);
     }
     /// <inheritdoc cref="SqliteTable{T}.ExecuteQuery(string, IEnumerable{object?})"/>