From 909f66e84183e18160e6b1f9914ef7b6543f40ca Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Fri, 1 Jun 2018 20:22:46 -0400 Subject: [PATCH] remove extra eventBus --- consensus/byzantine_test.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/consensus/byzantine_test.go b/consensus/byzantine_test.go index a8f559f60..d3be8c358 100644 --- a/consensus/byzantine_test.go +++ b/consensus/byzantine_test.go @@ -58,14 +58,11 @@ func TestByzantine(t *testing.T) { css[i].doPrevote = func(height int64, round int) {} } - eventBus := types.NewEventBus() + eventBus := css[i].eventBus eventBus.SetLogger(logger.With("module", "events", "validator", i)) - err := eventBus.Start() - require.NoError(t, err) - defer eventBus.Stop() eventChans[i] = make(chan interface{}, 1) - err = eventBus.Subscribe(context.Background(), testSubscriber, types.EventQueryNewBlock, eventChans[i]) + err := eventBus.Subscribe(context.Background(), testSubscriber, types.EventQueryNewBlock, eventChans[i]) require.NoError(t, err) conR := NewConsensusReactor(css[i], true) // so we dont start the consensus states