try fix

argon-chat · Jan 3, 2025 · 41b292d · 41b292d
1 parent 77e9b5e
commit 41b292d
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/Argon.Api/Features/Orleanse/Streams/NatsAdapterFactory.cs b/src/Argon.Api/Features/Orleanse/Streams/NatsAdapterFactory.cs
@@ -50,7 +50,17 @@ public ArgonEventBatch(StreamId streamId, object data, Type getType, StreamSeque
     {
         var sequenceToken = (EventSequenceTokenV2)SequenceToken;
 
-        return Data.OfType<T>().Select((@event, i) => Tuple.Create<T, StreamSequenceToken?>(@event, sequenceToken.CreateSequenceTokenForEvent(i)));
+        if (sequenceToken is null)
+            throw new NullReferenceException($"Fucking mom of sequenceToken null, original '{SequenceToken.GetType().FullName}'");
+        if (Data is null)
+            throw new NullReferenceException($"Fucking mom of Data null");
+
+        var eta = Data.OfType<T>().ToList();
+        if (eta is null)
+            throw new NullReferenceException($"Fucking mom of eta null");
+
+
+        return eta.Select((@event, i) => Tuple.Create<T, StreamSequenceToken?>(@event, sequenceToken.CreateSequenceTokenForEvent(i)));
     }
 
     public bool ImportRequestContext() => false;