SimpleEventBus extends EventBus { @Override protected <T> Future<T> throwAsync(T event) { final Collection<ListenerMethod> methods = getMethods(getClassName(event.getClass())); return this.executorService.submit(createRunnable(methods, event)); } SimpleEventBus(); final Collection<ListenerMethod> getMethods(final String eventType);  }
@Test void throwAsync() { try { final EventBus bus = createEventBus(); bus.registerListeners(new TestListenerClass()); Assertions.assertDoesNotThrow(() -> { bus.throwAsync("Hello World").get(); }); Assertions.assertTrue(indicateSuccess); } finally { indicateSuccess = false; } }