fix threading

Surveily · Nov 14, 2023 · 055ea6a · 055ea6a
1 parent 069f1a2
commit 055ea6a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/Orleans.Streaming.Grains/Grains/TransactionGrain.cs b/src/Orleans.Streaming.Grains/Grains/TransactionGrain.cs
@@ -144,7 +144,7 @@ public async Task FlushAsync()
 
         private async Task FlushTimerAsync(object arg)
         {
-            await this.AsReference<ITransactionGrain>().FlushAsync();
+            await Task.Run(async () => await this.AsReference<ITransactionGrain>().FlushAsync());
         }
 
         private async Task PersistAsync()

diff --git a/src/Orleans.Streaming.Grains/Grains/TransactionItemGrain.cs b/src/Orleans.Streaming.Grains/Grains/TransactionItemGrain.cs
@@ -65,7 +65,7 @@ public async Task PersistAsync()
 
         private async Task PersistTimerAsync(object arg)
         {
-            await this.AsReference<ITransactionItemGrain<T>>().PersistAsync();
+            await Task.Run(async () => await this.AsReference<ITransactionItemGrain<T>>().PersistAsync());
         }
     }
 }