Class EventBus

java.lang.Object

com.knezevic.edaf.v3.core.events.EventBus

All Implemented Interfaces:

AutoCloseable

public final class EventBus
extends Object
implements AutoCloseable

Thread-safe event fan-out used as the observability backbone.

Constructor Summary

Constructors

Constructor	Description
EventBus()

Method Summary

Modifier and Type	Method	Description
void	close()
void	publish(RunEvent event)	Publishes an event to all registered sinks.
void	register(EventSink sink)	Registers a sink.
int	sinkCount()	Returns number of currently registered sinks.

Methods inherited from class java.lang.Object

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

Constructor Details

EventBus

public EventBus()

Method Details

register

public void register(EventSink sink)

Registers a sink.

publish

public void publish(RunEvent event)

Publishes an event to all registered sinks.

sinkCount

public int sinkCount()

Returns number of currently registered sinks.

close

public void close()

Specified by:

close in interface AutoCloseable