| 625 | } |
| 626 | |
| 627 | func (db *DatabaseCollectionWithUser) MultiChangesFeed(ctx context.Context, chans base.Set, options ChangesOptions) (<-chan *ChangeEntry, error) { |
| 628 | if len(chans) == 0 { |
| 629 | return nil, nil |
| 630 | } |
| 631 | |
| 632 | if options.ChangesCtx == nil { |
| 633 | base.ErrorfCtx(ctx, "MultiChangesFeed: Changes Context missing") |
| 634 | } |
| 635 | |
| 636 | base.DebugfCtx(ctx, base.KeyChanges, "Int sequence multi changes feed...") |
| 637 | |
| 638 | return db.SimpleMultiChangesFeed(ctx, chans, options) |
| 639 | |
| 640 | } |
| 641 | |
| 642 | func (db *DatabaseCollectionWithUser) startChangeWaiter(trackUnusedSequences bool) *ChangeWaiter { |
| 643 | return db.mutationListener().NewWaiterWithChannels(channels.Set{}, db.user, trackUnusedSequences) |