Shutdown concurrently shuts down all known proxiers and waits for them *all* to complete.
(ctx context.Context)
| 120 | |
| 121 | // Shutdown concurrently shuts down all known proxiers and waits for them *all* to complete. |
| 122 | func (s *ServerProxyManager) Shutdown(ctx context.Context) error { |
| 123 | cg := utils.NewConcurrentGroup() |
| 124 | for _, proxy := range s.proxiers { |
| 125 | cg.Go(func() error { |
| 126 | return proxy.Shutdown(ctx) |
| 127 | }) |
| 128 | } |
| 129 | return cg.Wait() |
| 130 | } |
no test coverage detected