| 960 | }) |
| 961 | |
| 962 | type mockStreamingProvider struct { |
| 963 | mu sync.RWMutex |
| 964 | credentials auth.Credentials |
| 965 | err error |
| 966 | updates chan auth.Credentials |
| 967 | } |
| 968 | |
| 969 | func (m *mockStreamingProvider) Subscribe(listener auth.CredentialsListener) (auth.Credentials, auth.UnsubscribeFunc, error) { |
| 970 | if m.err != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected