Add "ToList" better deferred execution, and obsolete Execute. ALso introduced AsEnumerableAsync and more

Author: magiccodingman

Magic.IndexedDb/IndexDbManager.cs

@@ -229,7 +229,7 @@ private Expression<Func<T, bool>> PreprocessPredicate<T>(Expression<Func<T, bool
             return Expression.Lambda<Func<T, bool>>(newExpression, predicate.Parameters);
         }
 
-        internal async Task<IList<T>?> WhereV2Async<T>(
+        internal async Task<IEnumerable<T>?> WhereV2Async<T>(
             string storeName, List<string> jsonQuery, MagicQuery<T> query,
             CancellationToken cancellationToken) where T : class
         {
@@ -247,7 +247,7 @@ private Expression<Func<T, bool>> PreprocessPredicate<T>(Expression<Func<T, bool
                 new TypedArgument<bool?>(query?.ResultsUnique!),
             };
 
-            return await CallJsAsync<IList<T>>
+            return await CallJsAsync<IEnumerable<T>>
                 (IndexedDbFunctions.WHERE, cancellationToken,
                 args);
         }
@@ -572,5 +572,18 @@ internal async Task<T> CallJsAsync<T>(string functionName, CancellationToken tok
 
             return await magicJsInvoke.MagicStreamJsAsync<T>(functionName, token, args) ?? default;
         }
+
+
+        // Synchronous alternatives
+        internal void CallJs(string functionName, CancellationToken token, params ITypedArgument[] args)
+        {
+            CallJsAsync(functionName, token, args).GetAwaiter().GetResult();
+        }
+
+        internal T CallJs<T>(string functionName, CancellationToken token, params ITypedArgument[] args)
+        {
+            return CallJsAsync<T>(functionName, token, args).GetAwaiter().GetResult();
+        }
+
     }
 }

Magic.IndexedDb/Models/MagicQuery.cs

@@ -5,6 +5,7 @@
 using System.Linq;
 using System.Linq.Expressions;
 using System.Reflection;
+using System.Runtime.CompilerServices;
 using System.Text;
 using System.Threading.Tasks;
 
@@ -92,11 +93,55 @@ private MagicQuery<T> Last()
             return this;
         }
 
+        [Obsolete("Please use 'ToListAsync' or 'AsAsyncEnumerable' or 'ToList' or 'AsEnumerable'")]
         public async Task<IEnumerable<T>> Execute()
         {
             return await Manager.WhereV2Async<T>(SchemaName, JsonQueries, this, default) ?? Enumerable.Empty<T>();
         }
 
+        //.GetAwaiter().GetResult()
+
+        /// <summary>
+        /// safe to use, but emulates an IAsync until future implementation
+        /// </summary>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public async IAsyncEnumerable<T> AsAsyncEnumerable([EnumeratorCancellation] CancellationToken cancellationToken = default)
+        {
+            var results = await Manager.WhereV2Async<T>(SchemaName, JsonQueries, this, cancellationToken);
+
+            if (results != null)
+            {
+                foreach (var item in results)
+                {
+                    yield return item; // ✅ Stream results one at a time
+                }
+            }
+        }
+
+
+        public async Task<List<T>> ToListAsync()
+        {
+            return (await Manager.WhereV2Async<T>(SchemaName, JsonQueries, this, default))?.ToList() ?? new List<T>();
+        }
+
+        public IEnumerable<T> AsEnumerable()
+        {
+            return Manager.WhereV2Async<T>(SchemaName, JsonQueries, this, default)
+                          .GetAwaiter()
+                          .GetResult()
+                          ?? Enumerable.Empty<T>();
+        }
+
+        public List<T> ToList()
+        {
+            return Manager.WhereV2Async<T>(SchemaName, JsonQueries, this, default)
+                          .GetAwaiter()
+                          .GetResult()
+                          ?.ToList()
+                          ?? new List<T>();
+        }
+
         public async Task<int> Count()
         {
             var result = await Manager.WhereV2Async<T>(SchemaName, JsonQueries, this, default);

TestWasm/Pages/Home.razor

@@ -82,7 +82,7 @@
         <span style="color: #2A56C6;">await</span> manager.<span style="color: #2A56C6;">Where</span><span style="color: #A31515;">&lt;Person&gt;</span>(x =&gt; x.Name.<span style="color: #2A56C6;">StartsWith</span>(<span style="color: #A31515;">"c"</span>, <span style="color: #2A56C6;">StringComparison</span>.<span style="color: #2A56C6;">OrdinalIgnoreCase</span>)
         <span style="color: #2A56C6;">||</span> x.Name.<span style="color: #2A56C6;">StartsWith</span>(<span style="color: #A31515;">"l"</span>, <span style="color: #2A56C6;">StringComparison</span>.<span style="color: #2A56C6;">OrdinalIgnoreCase</span>)
         <span style="color: #2A56C6;">||</span> x.Name.<span style="color: #2A56C6;">StartsWith</span>(<span style="color: #A31515;">"j"</span>, <span style="color: #2A56C6;">StringComparison</span>.<span style="color: #2A56C6;">OrdinalIgnoreCase</span>) <span style="color: #2A56C6;">&amp;&amp;</span> x._Age <span style="color: #2A56C6;">&gt;</span> <span style="color: #2A56C6;">35</span>
-        ).<span style="color: #2A56C6;">OrderBy</span>(x =&gt; x._Id).<span style="color: #2A56C6;">Skip</span>(<span style="color: #2A56C6;">1</span>).<span style="color: #2A56C6;">Execute</span>();
+        ).<span style="color: #2A56C6;">OrderBy</span>(x =&gt; x._Id).<span style="color: #2A56C6;">Skip</span>(<span style="color: #2A56C6;">1</span>).<span style="color: #2A56C6;">ToListAsync</span>();
     </code>
 </pre>
 
@@ -117,7 +117,7 @@
                         new Person { Name = "Cathy", TestInt = 9, _Age = 22, GUIY = Guid.NewGuid(), DoNotMapTest = "I got away with reading Bobs diary.", Access = Person.Permissions.CanRead | Person.Permissions.CanWrite},
                         new Person { Name = "Bob", TestInt = 3 , _Age = 69, GUIY = Guid.NewGuid(), DoNotMapTest = "I caught Cathy reading my diary, but I'm too shy to confront her.", Access = Person.Permissions.CanRead },
                         new Person { Name = "Alex", TestInt = 3 , _Age = 80, GUIY = Guid.NewGuid(), DoNotMapTest = "I'm naked! But nobody can know!" }
-        };
+    };
                     await manager.AddRangeAsync(persons);
                 }
 
@@ -131,7 +131,9 @@
                 || x.Name.StartsWith("l", StringComparison.OrdinalIgnoreCase)
                 || x.Name.StartsWith("j", StringComparison.OrdinalIgnoreCase) && x._Age > 35
                 || x.Name.Contains("bo", StringComparison.OrdinalIgnoreCase)
-                ).OrderBy(x => x._Id).Skip(1).Execute();
+                ).OrderBy(x => x._Id).Skip(1).ToListAsync();
+
+
 
                 /*
                  * Still working on allowing nested