From 0f1c9bfb1b94ef627ca8f2d4ccb4b09af1072214 Mon Sep 17 00:00:00 2001
From: DmitriyMX <dimon550@gmail.com>
Date: Wed, 5 May 2021 20:09:32 +0300
Subject: [PATCH] =?UTF-8?q?=D0=B8=D0=BD=D1=82=D0=B5=D1=80=D1=84=D0=B5?=
 =?UTF-8?q?=D0=B9=D1=81=20EventBus?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/mc/protocol/utils/EventBus.java   | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)
 create mode 100644 protocol/src/main/java/mc/protocol/utils/EventBus.java

diff --git a/protocol/src/main/java/mc/protocol/utils/EventBus.java b/protocol/src/main/java/mc/protocol/utils/EventBus.java
new file mode 100644
index 0000000..036b25c
--- /dev/null
+++ b/protocol/src/main/java/mc/protocol/utils/EventBus.java
@@ -0,0 +1,17 @@
+package mc.protocol.utils;
+
+import mc.protocol.ChannelContext;
+import mc.protocol.State;
+import mc.protocol.packets.ClientSidePacket;
+
+public interface EventBus {
+
+	<P extends ClientSidePacket> void subscribe(State state, Class<P> packetClass, EventHandler<P> eventHandler);
+
+	<P extends ClientSidePacket> void emit(State state, ChannelContext<P> channelContext);
+
+	@FunctionalInterface
+	interface EventHandler<P extends ClientSidePacket> {
+		void handle(ChannelContext<P> channelContext);
+	}
+}