Closes set of feeds. Invoked on changes termination
(ctx context.Context, feeds map[channels.ID]*lateSequenceFeed)
| 1343 | |
| 1344 | // Closes set of feeds. Invoked on changes termination |
| 1345 | func (db *DatabaseCollectionWithUser) closeLateFeeds(ctx context.Context, feeds map[channels.ID]*lateSequenceFeed) { |
| 1346 | for _, feed := range feeds { |
| 1347 | db.closeLateFeed(ctx, feed) |
| 1348 | } |
| 1349 | } |
| 1350 | |
| 1351 | // Generate the changes for a specific list of doc ID's, only documents accessible to the user will generate |
| 1352 | // results. Only supports non-continuous changes, closes buffered channel before returning. |
no test coverage detected