Addressing comments

towns-protocol · Feb 10, 2025 · 70a1f5d · 70a1f5d
1 parent c8abfae
commit 70a1f5d
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/core/node/events/stream_ephemeral.go b/core/node/events/stream_ephemeral.go
@@ -42,12 +42,12 @@ func (s *StreamCache) onStreamCreated(
 			event.Stream.Flags&uint64(registries.StreamFlagSealed) != 0,
 		); err != nil {
 			logging.FromCtx(ctx).Errorw("Failed to normalize ephemeral stream", "err", err, "streamId", event.GetStreamId())
-		} else {
-			// Cache the stream
-			stream.mu.Lock()
-			s.cache.Store(stream.streamId, stream)
-			stream.mu.Unlock()
 		}
+
+		// Cache the stream
+		stream.mu.Lock()
+		s.cache.Store(stream.streamId, stream)
+		stream.mu.Unlock()
 	}()
 }