(feeds []<-chan *ChangeEntry, options ChangesOptions)
| 644 | } |
| 645 | |
| 646 | func (db *DatabaseCollectionWithUser) appendUserFeed(feeds []<-chan *ChangeEntry, options ChangesOptions) []<-chan *ChangeEntry { |
| 647 | userSeq := SequenceID{Seq: db.user.Sequence()} |
| 648 | if options.Since.Before(userSeq) { |
| 649 | name := db.user.Name() |
| 650 | if name == "" { |
| 651 | name = base.GuestUsername |
| 652 | } |
| 653 | entry := ChangeEntry{ |
| 654 | Seq: userSeq, |
| 655 | ID: "_user/" + name, |
| 656 | Changes: []ChangeByVersionType{}, |
| 657 | principalDoc: true, |
| 658 | } |
| 659 | userFeed := make(chan *ChangeEntry, 1) |
| 660 | userFeed <- &entry |
| 661 | close(userFeed) |
| 662 | feeds = append(feeds, userFeed) |
| 663 | } |
| 664 | return feeds |
| 665 | } |
| 666 | |
| 667 | func (col *DatabaseCollectionWithUser) checkForUserUpdates(ctx context.Context, userChangeCount uint64, changeWaiter *ChangeWaiter, isContinuous bool) (isChanged bool, newCount uint64, changedChannels channels.ChangedKeys, err error) { |
| 668 |
no test coverage detected