tasks []Task
}
+func newFakeSummarizer() *FakeSummarizer {
+ return &FakeSummarizer{}
+}
+
func (f *FakeSummarizer) Summarize(ctx context.Context, task Task) (string, error) {
f.mutex.Lock()
+
f.tasks = append(f.tasks, task)
f.active++
f.peak = max(f.peak, f.active)
defer func() {
f.mutex.Lock()
+
f.active--
f.mutex.Unlock()
}()
return line
}
-
-func newFakeSummarizer() *FakeSummarizer {
- return &FakeSummarizer{}
-}