Index: filter/count/tq.go |
diff --git a/filter/count/tq.go b/filter/count/tq.go |
index 65f0955b054e86be5a6027f843ba783f7579a4a4..379e69d3dc8956e190a35b4775d766dca8725f8c 100644 |
--- a/filter/count/tq.go |
+++ b/filter/count/tq.go |
@@ -42,6 +42,10 @@ func (t *tqCounter) Stats(queueNames []string, cb tq.RawStatsCB) error { |
return t.c.Stats.up(t.tq.Stats(queueNames, cb)) |
} |
+func (t *tqCounter) Testable() tq.Testable { |
+ return t.tq.Testable() |
+} |
+ |
// FilterTQ installs a counter TaskQueue filter in the context. |
func FilterTQ(c context.Context) (context.Context, *TQCounter) { |
state := &TQCounter{} |