()
| 172 | } |
| 173 | |
| 174 | func (h *Hub) Wait() error { |
| 175 | if !h.running { |
| 176 | return nil |
| 177 | } |
| 178 | timer := time.NewTimer(60 * time.Second) |
| 179 | defer timer.Stop() |
| 180 | select { |
| 181 | case <-h.closed: |
| 182 | case <-timer.C: |
| 183 | return fmt.Errorf("timed out waiting for hub stop") |
| 184 | } |
| 185 | return nil |
| 186 | } |