(ec *eventbus.Client, ctx context.Context, dump func(st *netmon.State))
| 129 | } |
| 130 | |
| 131 | func changeDeltaWatcher(ec *eventbus.Client, ctx context.Context, dump func(st *netmon.State)) func(*eventbus.Client) { |
| 132 | changeSub := eventbus.Subscribe[netmon.ChangeDelta](ec) |
| 133 | return func(ec *eventbus.Client) { |
| 134 | for { |
| 135 | select { |
| 136 | case <-ctx.Done(): |
| 137 | return |
| 138 | case <-ec.Done(): |
| 139 | return |
| 140 | case delta := <-changeSub.Events(): |
| 141 | if !delta.RebindLikelyRequired { |
| 142 | log.Printf("Network monitor fired; not a significant change") |
| 143 | return |
| 144 | } |
| 145 | log.Printf("Network monitor fired. New state:") |
| 146 | dump(delta.CurrentState()) |
| 147 | } |
| 148 | } |
| 149 | } |
| 150 | } |
| 151 | |
| 152 | func getURL(ctx context.Context, urlStr string) error { |
| 153 | if urlStr == "login" { |
no test coverage detected
searching dependent graphs…