diff --git a/src/main/java/de/extio/game_engine/event/EventExecutor.java b/src/main/java/de/extio/game_engine/event/EventExecutor.java index b863911..ffcbfca 100644 --- a/src/main/java/de/extio/game_engine/event/EventExecutor.java +++ b/src/main/java/de/extio/game_engine/event/EventExecutor.java @@ -10,6 +10,7 @@ import java.util.concurrent.StructuredTaskScope.FailedException; import java.util.concurrent.StructuredTaskScope.Joiner; import java.util.concurrent.StructuredTaskScope.Subtask; import java.util.concurrent.StructuredTaskScope.Subtask.State; +import java.util.function.Consumer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -57,7 +58,7 @@ public class EventExecutor { case 1: try { - consumers.getFirst().consumer().accept(event); + ((Consumer) consumers.getFirst().consumer()).accept(event); } catch (final NoSuchElementException e) { return; @@ -72,7 +73,7 @@ public class EventExecutor { tasks.clear(); for (final var consumer : consumers) { tasks.add(scope.fork(() -> { - consumer.consumer().accept(event); + ((Consumer) consumer.consumer()).accept(event); })); } diff --git a/src/main/java/de/extio/game_engine/event/EventHandlerRegistry.java b/src/main/java/de/extio/game_engine/event/EventHandlerRegistry.java index a75690d..219f88d 100644 --- a/src/main/java/de/extio/game_engine/event/EventHandlerRegistry.java +++ b/src/main/java/de/extio/game_engine/event/EventHandlerRegistry.java @@ -10,7 +10,7 @@ public class EventHandlerRegistry { private final ConcurrentMap, List> handlers = new ConcurrentHashMap<>(); - public void register(final Class eventClass, final String consumerId, final Consumer consumer) { + public void register(final Class eventClass, final String consumerId, final Consumer consumer) { final var eventConsumers = this.handlers.computeIfAbsent(eventClass, k -> new CopyOnWriteArrayList<>()); eventConsumers.removeIf(ec -> ec.id().equals(consumerId)); eventConsumers.add(new EventConsumer(consumerId, consumer)); @@ -27,6 +27,6 @@ public class EventHandlerRegistry { return this.handlers.get(eventClass); } - record EventConsumer(String id, Consumer consumer) { + record EventConsumer(String id, Consumer consumer) { } } diff --git a/src/main/java/de/extio/game_engine/event/EventService.java b/src/main/java/de/extio/game_engine/event/EventService.java index 6348b54..c4acda6 100644 --- a/src/main/java/de/extio/game_engine/event/EventService.java +++ b/src/main/java/de/extio/game_engine/event/EventService.java @@ -4,7 +4,7 @@ import java.util.function.Consumer; public interface EventService { - void register(Class eventClass, String consumerId, Consumer consumer); + void register(Class eventClass, String consumerId, Consumer consumer); void unregister(Class eventClass, String consumerId); diff --git a/src/main/java/de/extio/game_engine/event/EventServiceImpl.java b/src/main/java/de/extio/game_engine/event/EventServiceImpl.java index 2204119..b5fa94a 100644 --- a/src/main/java/de/extio/game_engine/event/EventServiceImpl.java +++ b/src/main/java/de/extio/game_engine/event/EventServiceImpl.java @@ -13,7 +13,7 @@ public class EventServiceImpl implements EventService { } @Override - public void register(final Class eventClass, final String consumerId, final Consumer consumer) { + public void register(final Class eventClass, final String consumerId, final Consumer consumer) { this.registry.register(eventClass, consumerId, consumer); }