Skip to content

Commit 4ffa2c1

Browse files
committed
Fixed initial messages bug in MessagesPullerAndEmitter
1 parent 8c90281 commit 4ffa2c1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

Core/Cleipnir.ResilientFunctions/Messaging/MessagesPullerAndEmitter.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,9 +83,9 @@ public async Task PullEvents(TimeSpan maxSinceLastSynced)
8383

8484
try
8585
{
86-
var storedMessages = _initialMessages ?? await _messageStore.GetMessages(_storedId, _skip);
87-
if (_initialMessages != null && maxSinceLastSynced == TimeSpan.Zero)
88-
storedMessages = storedMessages.Concat(await _messageStore.GetMessages(_storedId, _skip)).ToList();
86+
var storedMessages = maxSinceLastSynced == TimeSpan.Zero
87+
? await _messageStore.GetMessages(_storedId, _skip)
88+
: _initialMessages ?? await _messageStore.GetMessages(_storedId, _skip);
8989

9090
_initialMessages = null;
9191
_lastSynced = _utcNow();

0 commit comments

Comments
 (0)