diff --git a/rafthttp/transport_test.go b/rafthttp/transport_test.go index 09144f866..13a473190 100644 --- a/rafthttp/transport_test.go +++ b/rafthttp/transport_test.go @@ -146,10 +146,9 @@ func TestTransportErrorc(t *testing.T) { } tr.peers[1].send(raftpb.Message{}) - testutil.WaitSchedule() select { case <-errorc: - default: + case <-time.After(1 * time.Second): t.Fatalf("cannot receive error from errorc") } }