(t *testing.T)
| 137 | } |
| 138 | |
| 139 | func withEnabledErrorQueue(t *testing.T) { |
| 140 | t.Helper() |
| 141 | |
| 142 | prevQueueEnabled := redisqueue.Enabled() |
| 143 | redisqueue.SetEnabled(false) |
| 144 | redisqueue.SetEnabled(true) |
| 145 | |
| 146 | t.Cleanup(func() { |
| 147 | redisqueue.SetEnabled(false) |
| 148 | redisqueue.SetEnabled(prevQueueEnabled) |
| 149 | }) |
| 150 | } |
| 151 | |
| 152 | func requireErrorSubscriberPayload(t *testing.T, subscriber <-chan []byte) []byte { |
| 153 | t.Helper() |
no test coverage detected