Index: filter/count/tq.go |
diff --git a/filter/count/tq.go b/filter/count/tq.go |
index 379e69d3dc8956e190a35b4775d766dca8725f8c..bc0426b0c3611d010cd54e2ce4b45e8c0d53aff3 100644 |
--- a/filter/count/tq.go |
+++ b/filter/count/tq.go |
@@ -49,6 +49,11 @@ func (t *tqCounter) Testable() tq.Testable { |
// FilterTQ installs a counter TaskQueue filter in the context. |
func FilterTQ(c context.Context) (context.Context, *TQCounter) { |
state := &TQCounter{} |
+ state.AddMulti.init() |
+ state.DeleteMulti.init() |
+ state.Purge.init() |
+ state.Stats.init() |
+ |
return tq.AddRawFilters(c, func(ic context.Context, tq tq.RawInterface) tq.RawInterface { |
return &tqCounter{state, tq} |
}), state |