(actual interface{}, _ ...interface{})
| 200 | } |
| 201 | |
| 202 | func unpackWorker(actual interface{}, _ ...interface{}) (worker *subscribeWorker) { |
| 203 | if actual == nil { |
| 204 | return |
| 205 | } |
| 206 | |
| 207 | worker, _ = actual.(*subscribeWorker) |
| 208 | |
| 209 | return |
| 210 | } |
| 211 | |
| 212 | func (s *Service) start() (err error) { |
| 213 | if atomic.LoadInt32(&s.stopped) == 1 { |
no outgoing calls
no test coverage detected