|
|
@ -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
|
|
|
|