()
| 258 | } |
| 259 | |
| 260 | func (s *SubscriberReceiverResult) Captured() []SubscriberCaptured { |
| 261 | s.mu.Lock() |
| 262 | defer s.mu.Unlock() |
| 263 | out := make([]SubscriberCaptured, len(s.captured)) |
| 264 | copy(out, s.captured) |
| 265 | return out |
| 266 | } |
| 267 | |
| 268 | // SetStatus pins a non-200 response for the given path. Used by the |
| 269 | // auto-disable test to force the worker into the failure path. |