DataBus.java

package com.osroyale.game.event.bus;
 
import com.osroyale.game.event.Event;
import com.osroyale.game.event.listener.EventListener;
 
import java.util.LinkedHashSet;
import java.util.Set;

 
public final class DataBus {

    private static final Set<EventListener> listeners = new LinkedHashSet<>();

    private static final DataBus INSTANCE = new DataBus();

    private DataBus() {
 
    }

    public static DataBus getInstance() {
        return INSTANCE;
    }

    public void subscribe(EventListener listener) {
        listeners.add(listener);
    }

    public void unsubscribe(EventListener listener) {
        listeners.remove(listener);
    }

    public void publish(Event event) {
        listeners.forEach(it -> it.accept(event));
    }
 
}