This test is slightly flaky on CI
Peter Bourgon
8 years ago
| 24 | 24 | if err == nil { |
| 25 | 25 | t.Errorf("expected error, got nil") |
| 26 | 26 | } |
| 27 | calledEventHandler := false | |
| 27 | calledEventHandler := make(chan struct{}) | |
| 28 | 28 | eventHandler := func(event stdzk.Event) { |
| 29 | calledEventHandler = true | |
| 29 | close(calledEventHandler) | |
| 30 | 30 | } |
| 31 | 31 | c, err = NewClient( |
| 32 | 32 | []string{"localhost"}, |
| 57 | 57 | if want, have := payload, clientImpl.rootNodePayload; bytes.Compare(want[0], have[0]) != 0 || bytes.Compare(want[1], have[1]) != 0 { |
| 58 | 58 | t.Errorf("want %s, have %s", want, have) |
| 59 | 59 | } |
| 60 | // Allow EventHandler to be called | |
| 61 | time.Sleep(1 * time.Millisecond) | |
| 62 | 60 | |
| 63 | if want, have := true, calledEventHandler; want != have { | |
| 64 | t.Errorf("want %t, have %t", want, have) | |
| 61 | select { | |
| 62 | case <-calledEventHandler: | |
| 63 | case <-time.After(100 * time.Millisecond): | |
| 64 | t.Errorf("event handler never called") | |
| 65 | 65 | } |
| 66 | 66 | } |
| 67 | 67 | |