From 70a1f5d8e017c1cf7eaff83db2994d190d45c4e5 Mon Sep 17 00:00:00 2001 From: rbhnt Date: Mon, 10 Feb 2025 09:15:30 +0000 Subject: [PATCH] Addressing comments --- core/node/events/stream_ephemeral.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/core/node/events/stream_ephemeral.go b/core/node/events/stream_ephemeral.go index b4694e136..36f6356af 100644 --- 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() }() }