gradle: наводим порядок в зависимостях

protocol/build.gradle

@@ -1,9 +1,8 @@
 apply from: rootDir.toPath().resolve('logic.gradle').toFile()
 
 dependencies {
-    implementation libs.netty
-    implementation libs.reactor
-    implementation libs.guava
+    api libs.netty
+    api libs.reactor
     implementation libs.json
 
     testImplementation libs.lang3

protocol/src/main/java/mc/protocol/di/ProtocolModule.java

@@ -1,6 +1,5 @@
 package mc.protocol.di;
 
-import com.google.common.collect.ImmutableMap;
 import dagger.Module;
 import dagger.Provides;
 import io.netty.bootstrap.ServerBootstrap;
@@ -22,9 +21,11 @@ import mc.protocol.io.codec.ProtocolSplitter;
 import mc.protocol.packets.Packet;
 import reactor.core.publisher.Sinks;
 
+import javax.annotation.Nonnull;
 import javax.inject.Provider;
 import java.util.LinkedHashMap;
 import java.util.Map;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 @Module
@@ -54,7 +55,7 @@ public class ProtocolModule {
 
 		return new ChannelInitializer<>() {
 			@Override
-			protected void initChannel(SocketChannel socketChannel) {
+			protected void initChannel(@Nonnull SocketChannel socketChannel) {
 				ChannelPipeline pipeline = socketChannel.pipeline();
 				channelHandlerMapProvider.get().forEach(pipeline::addLast);
 			}
@@ -81,12 +82,8 @@ public class ProtocolModule {
 	@Provides
 	@ServerScope
 	Map<Class<? extends Packet>, Sinks.Many<ChannelContext>> provideObservedMap() {
-		ImmutableMap.Builder<Class<? extends Packet>, Sinks.Many<ChannelContext>> builder = ImmutableMap.builder();
-
-		Stream.of(State.values())
+		return Stream.of(State.values())
 				.flatMap(state -> state.getClientSidePackets().values().stream())
-				.forEach(packetClass -> builder.put(packetClass, Sinks.many().multicast().directBestEffort()));
-
-		return builder.build();
+				.collect(Collectors.toMap(packetClass -> packetClass, v -> Sinks.many().multicast().directBestEffort()));
 	}
 }

protocol/src/main/java/mc/protocol/serializer/ServerInfoSerializer.java

@@ -3,11 +3,13 @@ package mc.protocol.serializer;
 import com.eclipsesource.json.Json;
 import com.eclipsesource.json.JsonArray;
 import com.eclipsesource.json.JsonObject;
-import com.google.common.collect.Streams;
 import lombok.experimental.UtilityClass;
 import mc.protocol.model.ServerInfo;
 
+import java.util.Spliterator;
+import java.util.Spliterators;
 import java.util.stream.Collector;
+import java.util.stream.StreamSupport;
 
 @UtilityClass
 public class ServerInfoSerializer {
@@ -45,7 +47,9 @@ public class ServerInfoSerializer {
 	}
 
 	private static JsonArray jsonArrayAddAll(JsonArray jsonArrayTo, JsonArray jsonArrayFrom) {
-		Streams.stream(jsonArrayFrom).forEach(jsonArrayTo::add);
+		StreamSupport.stream(
+				Spliterators.spliteratorUnknownSize(jsonArrayFrom.iterator(), Spliterator.ORDERED), false)
+				.forEach(jsonArrayTo::add);
 		return jsonArrayTo;
 	}
 }