(numChannels int, numSources int)
| 1852 | } |
| 1853 | |
| 1854 | func NewTestDocChangedFeed(numChannels int, numSources int) *testDocChangedFeed { |
| 1855 | |
| 1856 | feed := &testDocChangedFeed{ |
| 1857 | fixedTime: channels.NewFeedTimestampFromNow(), |
| 1858 | sources: make([]uint64, numSources), |
| 1859 | } |
| 1860 | feed.channelNames = make([]string, numChannels) |
| 1861 | for i := 0; i < numChannels; i++ { |
| 1862 | feed.channelNames[i] = fmt.Sprintf("channel_%d", i) |
| 1863 | } |
| 1864 | feed.reset() |
| 1865 | return feed |
| 1866 | } |
| 1867 | |
| 1868 | // Reset sets nextSeq to 1, and reseeds sources |
| 1869 | func (f *testDocChangedFeed) reset() { |
no test coverage detected