| 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
|
|
|