Archived
0
This commit is contained in:
2021-05-03 00:07:33 +03:00
parent b768ba5bd9
commit 1a4600bdc9

View File

@@ -16,6 +16,8 @@ public class PacketInboundHandler extends SimpleChannelInboundHandler<Packet> {
@Override @Override
protected void channelRead0(ChannelHandlerContext ctx, Packet packet) { protected void channelRead0(ChannelHandlerContext ctx, Packet packet) {
if (observedMap.containsKey(packet.getClass())) {
observedMap.get(packet.getClass()).tryEmitNext(new ChannelContext<>(ctx, packet)); observedMap.get(packet.getClass()).tryEmitNext(new ChannelContext<>(ctx, packet));
} }
}
} }