Skip to content

Commit 326c11c

Browse files
committed
Fix network handler deprecations
1 parent 2a9d42b commit 326c11c

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/main/java/dev/compactmods/machines/core/CompactMachinesNet.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,13 +37,13 @@ public static void setupMessages() {
3737
CHANNEL.messageBuilder(TunnelAddedPacket.class, 1, NetworkDirection.PLAY_TO_CLIENT)
3838
.encoder(TunnelAddedPacket::encode)
3939
.decoder(TunnelAddedPacket::new)
40-
.consumer(TunnelAddedPacket::handle)
40+
.consumerMainThread(TunnelAddedPacket::handle)
4141
.add();
4242

4343
CHANNEL.messageBuilder(PlayerRequestedTeleportPacket.class, 2, NetworkDirection.PLAY_TO_SERVER)
4444
.encoder(PlayerRequestedTeleportPacket::encode)
4545
.decoder(PlayerRequestedTeleportPacket::new)
46-
.consumer(PlayerRequestedTeleportPacket::handle)
46+
.consumerMainThread(PlayerRequestedTeleportPacket::handle)
4747
.add();
4848
}
4949
}

src/main/java/dev/compactmods/machines/room/network/RoomNetworkHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,13 +24,13 @@ public static void setupMessages() {
2424
CHANNEL.messageBuilder(PlayerStartedRoomTrackingPacket.class, 1, NetworkDirection.PLAY_TO_SERVER)
2525
.encoder(PlayerStartedRoomTrackingPacket::encode)
2626
.decoder(PlayerStartedRoomTrackingPacket::new)
27-
.consumer(PlayerStartedRoomTrackingPacket::handle)
27+
.consumerMainThread(PlayerStartedRoomTrackingPacket::handle)
2828
.add();
2929

3030
CHANNEL.messageBuilder(InitialRoomBlockDataPacket.class, 2, NetworkDirection.PLAY_TO_CLIENT)
3131
.encoder(InitialRoomBlockDataPacket::toNetwork)
3232
.decoder(InitialRoomBlockDataPacket::fromNetwork)
33-
.consumer(InitialRoomBlockDataPacket::handle)
33+
.consumerMainThread(InitialRoomBlockDataPacket::handle)
3434
.add();
3535
}
3636
}

0 commit comments

Comments
 (0)