update all async

Author: YunchuWang

src/Client/OrchestrationServiceClientShim/ShimDurableEntityClient.cs

@@ -61,7 +61,9 @@ public override AsyncPageable<EntityMetadata> GetAllEntitiesAsync(EntityQuery? f
 
     /// <inheritdoc/>
     public override AsyncPageable<EntityMetadata<T>> GetAllEntitiesAsync<T>(EntityQuery? filter = null)
-        => this.GetAllEntitiesAsync(this.Convert<T>, filter);
+        => this.SupportsAsyncSerialization
+            ? this.GetAllEntitiesAsync(this.Convert<T>, filter)
+            : this.GetAllEntitiesAsync(this.ConvertSync<T>, filter);
 
     /// <inheritdoc/>
     public override async Task<EntityMetadata?> GetEntityAsync(
@@ -139,6 +141,39 @@ AsyncPageable<TMetadata> GetAllEntitiesAsync<TMetadata>(
         });
     }
 
+    AsyncPageable<TMetadata> GetAllEntitiesAsync<TMetadata>(
+        Func<EntityBackendQueries.EntityMetadata, Task<TMetadata>> selectAsync,
+        EntityQuery? filter)
+        where TMetadata : notnull
+    {
+        bool includeState = filter?.IncludeState ?? true;
+        bool includeTransient = filter?.IncludeTransient ?? false;
+        string startsWith = filter?.InstanceIdStartsWith ?? string.Empty;
+        DateTime? lastModifiedFrom = filter?.LastModifiedFrom?.UtcDateTime;
+        DateTime? lastModifiedTo = filter?.LastModifiedTo?.UtcDateTime;
+
+        return Pageable.Create(async (continuation, size, cancellation) =>
+        {
+            continuation ??= filter?.ContinuationToken;
+            size ??= filter?.PageSize;
+            EntityBackendQueries.EntityQueryResult result = await this.Queries.QueryEntitiesAsync(
+                new EntityBackendQueries.EntityQuery()
+                {
+                    InstanceIdStartsWith = startsWith,
+                    LastModifiedFrom = lastModifiedFrom,
+                    LastModifiedTo = lastModifiedTo,
+                    IncludeTransient = includeTransient,
+                    IncludeState = includeState,
+                    ContinuationToken = continuation,
+                    PageSize = size,
+                },
+                cancellation);
+
+            TMetadata[] items = await Task.WhenAll(result.Results.Select(selectAsync));
+            return new Page<TMetadata>(items, result.ContinuationToken);
+        });
+    }
+
     async Task<EntityMetadata<T>> Convert<T>(EntityBackendQueries.EntityMetadata metadata)
     {
         T? state = this.SupportsAsyncSerialization
@@ -155,6 +190,20 @@ async Task<EntityMetadata<T>> Convert<T>(EntityBackendQueries.EntityMetadata met
             };
     }
 
+    EntityMetadata<T> ConvertSync<T>(EntityBackendQueries.EntityMetadata metadata)
+    {
+        T? state = this.Converter.Deserialize<T>(metadata.SerializedState);
+
+        return new(
+            metadata.EntityId.ConvertFromCore(),
+            state)
+            {
+                LastModifiedTime = metadata.LastModifiedTime,
+                BacklogQueueSize = metadata.BacklogQueueSize,
+                LockedBy = metadata.LockedBy,
+            };
+    }
+
     async Task<EntityMetadata<T>?> Convert<T>(EntityBackendQueries.EntityMetadata? metadata)
     {
         if (metadata is null)