diff options
author | zaaarf <me@zaaarf.foo> | 2024-06-01 01:23:41 +0200 |
---|---|---|
committer | zaaarf <me@zaaarf.foo> | 2024-06-01 01:24:03 +0200 |
commit | baf61fb98ec190e5aaeea6d344749ac50a9e4079 (patch) | |
tree | a9cd503ab6bdf85715f6c3326c6b5b4dbfbe65f2 /src/main | |
parent | 4badb7ce926f0a65cc3485bdd53081ab4aff25b0 (diff) |
feat: API simplification, allow multiple instances
Diffstat (limited to 'src/main')
-rw-r--r-- | src/main/java/ftbsc/geb/GEB.java | 20 | ||||
-rw-r--r-- | src/main/java/ftbsc/geb/api/IBus.java | 5 | ||||
-rw-r--r-- | src/main/java/ftbsc/geb/api/IEventDispatcher.java | 5 | ||||
-rw-r--r-- | src/main/java/ftbsc/geb/api/IListener.java | 7 |
4 files changed, 20 insertions, 17 deletions
diff --git a/src/main/java/ftbsc/geb/GEB.java b/src/main/java/ftbsc/geb/GEB.java index 4d802f6..86e9be5 100644 --- a/src/main/java/ftbsc/geb/GEB.java +++ b/src/main/java/ftbsc/geb/GEB.java @@ -7,6 +7,7 @@ import ftbsc.geb.api.IListener; import java.util.Map; import java.util.ServiceLoader; +import java.util.Set; import java.util.concurrent.ConcurrentHashMap; /** @@ -17,7 +18,7 @@ public class GEB implements IBus { /** * A {@link Map} tying each listener class to its instance. */ - private final Map<Class<? extends IListener>, IListener> listenerMap; + private final Map<Class<? extends IListener>, Set<IListener>> listenerMap; /** * A {@link Map} tying each event class to the appropriate dispatcher. @@ -31,7 +32,7 @@ public class GEB implements IBus { this.listenerMap = new ConcurrentHashMap<>(); this.dispatchMap = new ConcurrentHashMap<>(); for(IEventDispatcher dispatcher : ServiceLoader.load(IEventDispatcher.class)) - dispatchMap.put(dispatcher.eventType(), dispatcher); + this.dispatchMap.put(dispatcher.eventType(), dispatcher); } /** @@ -40,7 +41,10 @@ public class GEB implements IBus { */ @Override public void registerListener(IListener listener) { - this.listenerMap.put(listener.getClass(), listener); + this.listenerMap.putIfAbsent( + listener.getClass(), + ConcurrentHashMap.newKeySet() + ); } /** @@ -49,13 +53,19 @@ public class GEB implements IBus { */ @Override public void unregisterListener(IListener listener) { - this.listenerMap.remove(listener.getClass()); + this.listenerMap.computeIfPresent( + listener.getClass(), + (k, l) -> { + l.remove(listener); + return l; + } + ); } /** * Dispatches an event, calling all of its listeners that are subscribed to this bus. * @param event the event to fire - * @return true if the event was canceled, false otherwise + * @return false if the event was canceled, true otherwise */ @Override public boolean handleEvent(IEvent event) { diff --git a/src/main/java/ftbsc/geb/api/IBus.java b/src/main/java/ftbsc/geb/api/IBus.java index f27004b..485cf74 100644 --- a/src/main/java/ftbsc/geb/api/IBus.java +++ b/src/main/java/ftbsc/geb/api/IBus.java @@ -14,9 +14,6 @@ public interface IBus { /** * Unregister a listener from the bus. - * While sensible implementations can get this quite fast, it's generally - * faster to use {@link IListener#isActive()}, so only use this if you - * *mean* to unregister for good. * @param listener the listener */ void unregisterListener(IListener listener); @@ -24,7 +21,7 @@ public interface IBus { /** * Dispatches an event, calling all of its listeners that are subscribed to this bus. * @param event the event to fire - * @return true if the event was canceled, false otherwise + * @return false if the event was canceled, true otherwise */ boolean handleEvent(IEvent event); } diff --git a/src/main/java/ftbsc/geb/api/IEventDispatcher.java b/src/main/java/ftbsc/geb/api/IEventDispatcher.java index e736706..ef13f0b 100644 --- a/src/main/java/ftbsc/geb/api/IEventDispatcher.java +++ b/src/main/java/ftbsc/geb/api/IEventDispatcher.java @@ -1,6 +1,7 @@ package ftbsc.geb.api; import java.util.Map; +import java.util.Set; /** * The interface that the generated dispatchers will all use. @@ -12,10 +13,10 @@ public interface IEventDispatcher { /** * Calls all listeners for the given event. * @param event the event to call - * @param listeners a map mapping each {@link IListener} class to its instance + * @param listeners a map mapping each {@link IListener} class to its instances * @return the value {@link IBus#handleEvent(IEvent)} will return for this */ - boolean callListeners(IEvent event, Map<Class<? extends IListener>, IListener> listeners); + boolean callListeners(IEvent event, Map<Class<? extends IListener>, Set<IListener>> listeners); /** * @return the {@link Class} representing the event this dispatcher works with diff --git a/src/main/java/ftbsc/geb/api/IListener.java b/src/main/java/ftbsc/geb/api/IListener.java index fa8978f..859fce9 100644 --- a/src/main/java/ftbsc/geb/api/IListener.java +++ b/src/main/java/ftbsc/geb/api/IListener.java @@ -4,9 +4,4 @@ package ftbsc.geb.api; * The common interface for all classes that contain GEB listeners. * @since 0.1.0 */ -public interface IListener { - /** - * @return whether the listeners in this class should be considered to be active - */ - boolean isActive(); -} +public interface IListener {}
\ No newline at end of file |