Correct thread

src/main/java/ciomek/loon/mixin/WorldServerMixin.java

@@ -105,13 +105,20 @@ public class WorldServerMixin {
 		IRequest request;
 		while ((request = RequestManager.pollRequest()) != null) {
 			IRequest current = request;
-			EXECUTOR.submit(() -> {
+			if (current.requireTickThread()) {
+				runRequest(current);
+			} else {
+				EXECUTOR.submit(() -> runRequest(current));
+			}
+		}
+	}
+
+	@Unique
+	private void runRequest(IRequest request) {
 		try {
-					current.handle(mcServer);
+			request.handle(mcServer);
 		} catch (Exception e) {
-					Loon.LOGGER.error("Failed to handle request: {}, {}", current.getClass().getSimpleName(), e);
+			Loon.LOGGER.error("Failed to handle request: {}, {}", request.getClass().getSimpleName(), e);
-				}
-			});
 		}
 	}
 }

src/main/java/ciomek/loon/mqtt/request/ChunkMapRequest.java

@@ -19,6 +19,8 @@ import java.util.ArrayList;
 import java.util.List;
 
 public record ChunkMapRequest(int xStart, int xEnd, int zStart, int zEnd) implements IRequest {
+	private static final boolean REQUIRE_TICK_THREAD = false;
+
 	@Override
 	public void handle(MinecraftServer server) {
 		World world = server.getDimensionWorld(0);
@@ -72,10 +74,11 @@ public record ChunkMapRequest(int xStart, int xEnd, int zStart, int zEnd) implem
 
 	Chunk resolveChunk(World world, ChunkProvider provider, ChunkLoader loader, int x, int z)
 	{
+		if (REQUIRE_TICK_THREAD) {
 			ChunkPos chunkPos = new ChunkPos(x, z);
-
 			if (provider.isChunkLoaded(chunkPos))
 				return world.getChunk(chunkPos);
+		}
 
 		if (loader == null || !loader.chunkExists(world, x, z))
 			return null;
@@ -86,4 +89,10 @@ public record ChunkMapRequest(int xStart, int xEnd, int zStart, int zEnd) implem
 			return null;
 		}
 	}
+
+	@Override
+	public boolean requireTickThread()
+	{
+		return REQUIRE_TICK_THREAD;
+	}
 }

src/main/java/ciomek/loon/mqtt/request/IRequest.java

@@ -6,4 +6,8 @@ import net.minecraft.server.entity.player.PlayerServer;
 public interface IRequest
 {
 	void handle(MinecraftServer server);
+	default boolean requireTickThread()
+	{
+		return true;
+	}
 }