From 79e56dd7332d514a39678c54eee89f99e0360dc2 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 2 Aug 2022 17:05:13 +0100 Subject: [PATCH] Revert "Fix issue with sync API not advancing. (#2603)" This reverts commit 6b6b420b9f467d053fd1fe3d1872f94c0bcf8300. --- syncapi/streams/stream_pdu.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index 1003208fd..1832adbe5 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -261,9 +261,9 @@ func (p *PDUStreamProvider) addRoomDeltaToResponse( var pos types.StreamPosition if _, pos, err = p.DB.PositionInTopology(ctx, mostRecentEventID); err == nil { switch { - case r.Backwards && pos < latestPosition: + case r.Backwards && pos > latestPosition: fallthrough - case !r.Backwards && pos > latestPosition: + case !r.Backwards && pos < latestPosition: latestPosition = pos } }