Method closeLateFeed

db/changes.go:1334–1342

Closes a single late sequence feed.

(ctx context.Context, feedHandler *lateSequenceFeed)

// Closes a single late sequence feed.
func (db *DatabaseCollectionWithUser) closeLateFeed(ctx context.Context, feedHandler *lateSequenceFeed) {
	singleChannelCache, err := db.changeCache().getChannelCache().getSingleChannelCache(ctx, feedHandler.channel)
	if err != nil || !singleChannelCache.SupportsLateFeed() {
		return
	}
	if singleChannelCache.LateSequenceUUID() == feedHandler.lateSequenceUUID {
		singleChannelCache.ReleaseLateSequenceClient(feedHandler.lastSequence)
	}
}

// Closes set of feeds.  Invoked on changes termination
func (db *DatabaseCollectionWithUser) closeLateFeeds(ctx context.Context, feeds map[channels.ID]*lateSequenceFeed) {