(c *check.C)
| 22 | } |
| 23 | |
| 24 | func (s *S) TestLogStreamTrackerShutdown(c *check.C) { |
| 25 | l := appTypes.NewMockLogWatcher() |
| 26 | logTracker.add(l) |
| 27 | logTracker.Shutdown(context.Background()) |
| 28 | select { |
| 29 | case <-l.Chan(): |
| 30 | case <-time.After(5 * time.Second): |
| 31 | c.Fatal("timed out waiting for channel to close") |
| 32 | } |
| 33 | } |