AbstractEventBus implements EventBus { @Override public void fire(Object event) { forEachListener(event, l -> l.onEvent(event)); }  @Override void addListener(Class<T> eventClass, EventListener<T> listener); @Override void fire(Object event); @Override void fireAsync(Object event);  }
@Test public void testFire() { final AtomicBoolean fired = new AtomicBoolean(false); EventListener<Object> listener = evt -> fired.set(true); EventBus eventBus = createEventBus(); eventBus.addListener(Object.class, listener); eventBus.fire(new Object()); assertThat(fired.get(), is(true)); }