diff --git a/syncapi/storage/shared/stream_receipt.go b/syncapi/storage/shared/stream_receipt.go index 7ec5fa2c6..1ad2d141f 100644 --- a/syncapi/storage/shared/stream_receipt.go +++ b/syncapi/storage/shared/stream_receipt.go @@ -28,7 +28,7 @@ func (p *ReceiptStreamProvider) CompleteSync( ctx context.Context, req *types.SyncRequest, ) types.StreamPosition { - return p.LatestPosition(ctx) + return p.IncrementalSync(ctx, req, 0, p.LatestPosition(ctx)) } func (p *ReceiptStreamProvider) IncrementalSync( diff --git a/syncapi/storage/shared/stream_typing.go b/syncapi/storage/shared/stream_typing.go index ba8c59cc2..767d8ca50 100644 --- a/syncapi/storage/shared/stream_typing.go +++ b/syncapi/storage/shared/stream_typing.go @@ -19,7 +19,7 @@ func (p *TypingStreamProvider) CompleteSync( // It isn't beneficial to send previous typing notifications // after a complete sync, so just return the latest position // and otherwise do nothing. - return p.LatestPosition(ctx) + return p.IncrementalSync(ctx, req, 0, p.LatestPosition(ctx)) } func (p *TypingStreamProvider) IncrementalSync(