Fix bug

sillsdev · Jun 28, 2024 · 5c69aca · 5c69aca
1 parent 06cb085
commit 5c69aca
Showing 1 changed file with 14 additions and 13 deletions.
diff --git a/src/SIL.Machine.AspNetCore/Services/ServalPlatformOutboxHandler.cs b/src/SIL.Machine.AspNetCore/Services/ServalPlatformOutboxHandler.cs
@@ -66,7 +66,7 @@ await _client.BuildRestartingAsync(
             case ServalPlatformMessageMethod.InsertPretranslations:
 
                 {
-                    Stream targetPretranslateStream = await _sharedFileService.OpenReadAsync(
+                    using Stream targetPretranslateStream = await _sharedFileService.OpenReadAsync(
                         $"outbox/{message.Id}",
                         cancellationToken
                     );
@@ -77,23 +77,24 @@ await _client.BuildRestartingAsync(
                             cancellationToken
                         )
                         .OfType<Pretranslation>();
-                    IAsyncEnumerable<InsertPretranslationRequest> requests = pretranslations.Select(
-                        p => new InsertPretranslationRequest
-                        {
-                            EngineId = message.RequestContent!,
-                            CorpusId = p.CorpusId,
-                            TextId = p.TextId,
-                            Refs = { p.Refs },
-                            Translation = p.Translation
-                        }
-                    );
 
                     using var call = _client.InsertPretranslations(cancellationToken: cancellationToken);
-                    await foreach (var request in requests)
+                    await foreach (Pretranslation? pretranslation in pretranslations)
                     {
-                        await call.RequestStream.WriteAsync(request, cancellationToken: cancellationToken);
+                        await call.RequestStream.WriteAsync(
+                            new InsertPretranslationRequest
+                            {
+                                EngineId = message.RequestContent!,
+                                CorpusId = pretranslation.CorpusId,
+                                TextId = pretranslation.TextId,
+                                Refs = { pretranslation.Refs },
+                                Translation = pretranslation.Translation
+                            },
+                            cancellationToken
+                        );
                     }
                     await call.RequestStream.CompleteAsync();
+                    await call;
                 }
                 break;
             case ServalPlatformMessageMethod.IncrementTranslationEngineCorpusSize: