throw if journal fails instead of waiting forever

fiskaltrust · Sep 19, 2024 · e572c0e · e572c0e
1 parent b8ee2b0
commit e572c0e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/fiskaltrust.Launcher/Extensions/WebApplicationExtensions.cs b/src/fiskaltrust.Launcher/Extensions/WebApplicationExtensions.cs
@@ -29,6 +29,8 @@ public static WebApplication AddQueueEndpoints(this WebApplication app, IPOS pos
             {
                 var pipe = new Pipe();
                 var journal = pos.JournalAsync(new JournalRequest { ftJournalType = type, From = from ?? 0, To = to ?? 0 });
+                // Throws if something failed in the request. Does not pop the first element
+                await journal.FirstAsync();
                 var _ = Task.Run(async () =>
                 {
                     await journal.ForEachAwaitAsync(async b => await pipe.Writer.WriteAsync(new ReadOnlyMemory<byte>(b.Chunk.ToArray())));