From db07e9b3659a187c051d860756093e4138bfc0cf Mon Sep 17 00:00:00 2001 From: Till Faelligen <2353100+S7evinK@users.noreply.github.com> Date: Mon, 26 Sep 2022 15:36:11 +0200 Subject: [PATCH] Comment --- syncapi/streams/stream_notificationdata.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/syncapi/streams/stream_notificationdata.go b/syncapi/streams/stream_notificationdata.go index c789d7a23..f8f3eb73b 100644 --- a/syncapi/streams/stream_notificationdata.go +++ b/syncapi/streams/stream_notificationdata.go @@ -32,6 +32,8 @@ func (p *NotificationDataStreamProvider) IncrementalSync( req *types.SyncRequest, from, _ types.StreamPosition, ) types.StreamPosition { + // Always get the latest data, as this might have advanced while waiting + // for other streams to prepare their responses and add/updated notifications. to := p.LatestPosition(ctx) countsByRoom, err := p.DB.GetUserUnreadNotificationCounts(ctx, req.Device.UserID, from, to) if err != nil {