From c4a6a019084cfd01e15c1e9b9d3dedf51b037a6a Mon Sep 17 00:00:00 2001
From: DmitriyMX <dimon550@gmail.com>
Date: Wed, 5 May 2021 20:43:09 +0300
Subject: [PATCH] =?UTF-8?q?=D1=83=D0=B1=D0=B8=D1=80=D0=B0=D0=B5=D0=BC=20re?=
 =?UTF-8?q?actor?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 protocol/build.gradle                         |  1 -
 protocol/src/main/java/mc/protocol/State.java | 18 ------------------
 2 files changed, 19 deletions(-)

diff --git a/protocol/build.gradle b/protocol/build.gradle
index 03ac861..b27f6a5 100644
--- a/protocol/build.gradle
+++ b/protocol/build.gradle
@@ -2,7 +2,6 @@ apply from: rootDir.toPath().resolve('logic.gradle').toFile()
 
 dependencies {
     api libs.netty
-    api libs.reactor
     implementation libs.json
 
     testImplementation libs.lang3
diff --git a/protocol/src/main/java/mc/protocol/State.java b/protocol/src/main/java/mc/protocol/State.java
index 180f4d7..e94fe07 100644
--- a/protocol/src/main/java/mc/protocol/State.java
+++ b/protocol/src/main/java/mc/protocol/State.java
@@ -8,12 +8,9 @@ import mc.protocol.packets.PingPacket;
 import mc.protocol.packets.ServerSidePacket;
 import mc.protocol.packets.client.*;
 import mc.protocol.packets.server.*;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Sinks;
 
 import javax.annotation.Nullable;
 import java.util.Collections;
-import java.util.HashMap;
 import java.util.Map;
 
 @RequiredArgsConstructor
@@ -83,9 +80,6 @@ public enum State {
 	private final Map<Integer, Class<? extends ClientSidePacket>> clientSidePackets;
 	private final Map<Class<? extends ServerSidePacket>, Integer> serverSidePackets;
 
-	@SuppressWarnings("rawtypes")
-	private final Map<Class<? extends ClientSidePacket>, Sinks.Many<ChannelContext>> observedMap = new HashMap<>();
-
 	State(int id, Map<Integer, Class<? extends ClientSidePacket>> clientSidePackets) {
 		this.id = id;
 		this.clientSidePackets = clientSidePackets;
@@ -101,16 +95,4 @@ public enum State {
 	public Integer getServerSidePacketId(Class<? extends Packet> clazz) {
 		return serverSidePackets == null ? null : serverSidePackets.get(clazz);
 	}
-
-
-	@SuppressWarnings("rawtypes")
-	public <P extends ClientSidePacket> Sinks.Many<ChannelContext> getPacketSinks(Class<P> packetClass) {
-		return observedMap.get(packetClass);
-	}
-
-	@SuppressWarnings("unchecked")
-	public <P extends ClientSidePacket> Flux<ChannelContext<P>> packetFlux(Class<P> packetClass) {
-		return observedMap.computeIfAbsent(packetClass, aClass -> Sinks.many().multicast().directBestEffort())
-				.asFlux().map(ChannelContext.class::cast);
-	}
 }