Package com.helix.core.events

Class EventBus

java.lang.Object

com.helix.core.events.EventBus

All Implemented Interfaces:

AutoCloseable

public class EventBus
extends Object
implements AutoCloseable

Thread-safe EventBus supporting synchronous and asynchronous event publishing and type-safe subscriptions.

Constructor Summary

Constructors

Constructor	Description
EventBus()
EventBus(ExecutorService asyncExecutor)

Method Summary

Modifier and Type	Method	Description
void	close()
void	publish(EngineEvent event)
CompletableFuture<Void>	publishAsync(EngineEvent event)
void	subscribe(EventType eventType, EventListener<EngineEvent> listener)
void	unsubscribe(EventType eventType, EventListener<EngineEvent> listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EventBus

public EventBus()

EventBus

public EventBus(ExecutorService asyncExecutor)

Method Details

subscribe

public void subscribe(EventType eventType,
 EventListener<EngineEvent> listener)

unsubscribe

public void unsubscribe(EventType eventType,
 EventListener<EngineEvent> listener)

publish

public void publish(EngineEvent event)

publishAsync

public CompletableFuture<Void> publishAsync(EngineEvent event)

close

public void close()

Specified by:

close in interface AutoCloseable