| 3617 | } |
| 3618 | |
| 3619 | type pubsubReinitSpy struct { |
| 3620 | pubsub.Pubsub |
| 3621 | sync.Mutex |
| 3622 | triedToSubscribe chan string |
| 3623 | expectedEvent string |
| 3624 | } |
| 3625 | |
| 3626 | func (p *pubsubReinitSpy) Subscribe(event string, listener pubsub.Listener) (cancel func(), err error) { |
| 3627 | cancel, err = p.Pubsub.Subscribe(event, listener) |
nothing calls this directly
no outgoing calls
no test coverage detected