Method DocIDChangesFeed

db/changes.go:1353–1386

Generate the changes for a specific list of doc ID's, only documents accessible to the user will generate results. Only supports non-continuous changes, closes buffered channel before returning.

(ctx context.Context, userChannels base.Set, explicitDocIds []string, options ChangesOptions)

// Generate the changes for a specific list of doc ID's, only documents accessible to the user will generate
// results. Only supports non-continuous changes, closes buffered channel before returning.
func (db *DatabaseCollectionWithUser) DocIDChangesFeed(ctx context.Context, userChannels base.Set, explicitDocIds []string, options ChangesOptions) (<-chan *ChangeEntry, error) {

	// Subroutine that creates a response row for a document:
	output := make(chan *ChangeEntry, len(explicitDocIds))
	defer close(output)
	rowMap := make(map[uint64]*ChangeEntry)

	// Sort results by sequence
	var sequences base.SortedUint64Slice
	for _, docID := range explicitDocIds {
		row, err := createChangesEntry(ctx, docID, db, options)
		if err != nil {
			return nil, err
		}
		if row != nil {
			rowMap[row.Seq.Seq] = row
			sequences = append(sequences, row.Seq.Seq)
		}
	}

	// Send ChangeEntries sorted by sequenceID
	sequences.Sort()
	for _, sequence := range sequences {
		output <- rowMap[sequence]
		if options.Limit > 0 {
			options.Limit--
			if options.Limit == 0 {
				break
			}
		}
	}

	return output, nil
}

// createChangesEntry is used when creating a doc ID filtered changes feed
func createChangesEntry(ctx context.Context, docid string, db *DatabaseCollectionWithUser, options ChangesOptions) (*ChangeEntry, error) {