fix: writing failed events

src/Fluss.HotChocolate.IntegrationTest/HotChocolateTest.cs

@@ -104,7 +104,7 @@ private async Task<Channel<List<Guid>>> SubscribeToTodos(CancellationToken ct)
         socket.Options.AddSubProtocol("graphql-transport-ws");
         await socket.ConnectAsync(new Uri(Address.Replace("http", "ws") + "/graphql"), CancellationToken.None);
 
-        Task.Run(async () =>
+        _ = Task.Run(async () =>
         {
             while (true)
             {

src/Fluss.UnitTest/Core/UnitOfWork/UnitOfWorkTest.cs

@@ -35,7 +35,7 @@ public UnitOfWorkTest()
 
         _unitOfWorkFactory = new UnitOfWorkFactory(
             new ServiceCollection()
-                .AddScoped(_ => GetUnitOfWork())
+                .AddTransient(_ => GetUnitOfWork())
                 .BuildServiceProvider());
     }
 
@@ -332,6 +332,33 @@ await Assert.ThrowsAsync<InvalidOperationException>(async () =>
         });
     }
 
+    [Fact]
+    public async Task FailingCommitDoesNotCacheEventsToWrite()
+    {
+        _policies.Add(new AllowAllPolicy());
+
+        try
+        {
+            await _unitOfWorkFactory.Commit(async unitOfWork =>
+            {
+                var aggregate = await unitOfWork.GetAggregate<TestAggregate, int>(100);
+                await aggregate.Create();
+
+                throw new Exception();
+            });
+        }
+        catch
+        {
+        }
+
+        await _unitOfWorkFactory.Commit(_ => ValueTask.CompletedTask);
+
+        var unitOfWork = GetUnitOfWork();
+        var aggregate = await unitOfWork.GetAggregate<TestAggregate, int>(100);
+
+        Assert.False(aggregate.Exists);
+    }
+
     private record TestRootReadModel : RootReadModel
     {
         public int GotEvents { get; private init; }

src/Fluss/UnitOfWork/UnitOfWork.cs

@@ -105,6 +105,7 @@ public ValueTask Return()
         _validator = null;
         _userIdProvider = null;
         _consistentVersion = null;
+        PublishedEventEnvelopes.Clear();
         _readModels.Clear();
         _isInstantiated = false;