mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-26 00:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix complete sync for receipt, typing

Browse source
This commit is contained in:
Neil Alexander 2021-01-07 09:31:40 +00:00
parent 3843d076bc
commit 98707e1554
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
syncapi/storage/shared/stream_receipt.go
View file

@ -28,7 +28,7 @@ func (p *ReceiptStreamProvider) CompleteSync(
ctx context.Context, ctx context.Context,
req *types.SyncRequest, req *types.SyncRequest,
) types.StreamPosition { ) types.StreamPosition {
return p.LatestPosition(ctx) return p.IncrementalSync(ctx, req, 0, p.LatestPosition(ctx))
} }
func (p *ReceiptStreamProvider) IncrementalSync( func (p *ReceiptStreamProvider) IncrementalSync(

2
syncapi/storage/shared/stream_typing.go
View file

@ -19,7 +19,7 @@ func (p *TypingStreamProvider) CompleteSync(
// It isn't beneficial to send previous typing notifications // It isn't beneficial to send previous typing notifications
// after a complete sync, so just return the latest position // after a complete sync, so just return the latest position
// and otherwise do nothing. // and otherwise do nothing.
return p.LatestPosition(ctx) return p.IncrementalSync(ctx, req, 0, p.LatestPosition(ctx))
} }
func (p *TypingStreamProvider) IncrementalSync( func (p *TypingStreamProvider) IncrementalSync(