it works

src/main/java/com/github/creeper123123321/viarift/handler/VRDecodeHandler.java

@@ -94,13 +94,14 @@ public class VRDecodeHandler extends ByteToMessageDecoder {
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-        if (PipelineUtil.containsCause(cause, CancelException.class)) return;
+        if (PipelineUtil.containsCause(cause, CancelException.class)) {
-        if (user.isActive()) {
+            if (user.isActive()) {
-            Iterator<Runnable> iterator = user.getPostProcessingTasks().iterator();
+                Runnable runnable;
-            while (iterator.hasNext()) {
+                while ((runnable = user.getPostProcessingTasks().poll()) != null) {
-                iterator.next().run();
+                    runnable.run();
-                iterator.remove();
+                }
             }
+            return;
         }
         super.exceptionCaught(ctx, cause);
     }
@@ -109,13 +110,11 @@ public class VRDecodeHandler extends ByteToMessageDecoder {
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
         super.channelRead(ctx, msg);
         if (user.isActive()) {
-            Iterator<Runnable> iterator = user.getPostProcessingTasks().iterator();
+            Runnable runnable;
-            while (iterator.hasNext()) {
+            while ((runnable = user.getPostProcessingTasks().poll()) != null) {
-                iterator.next().run();
+                runnable.run();
-                iterator.remove();
             }
         }
-        // todo implement to other platforms
     }
 
     @Override

src/main/java/com/github/creeper123123321/viarift/handler/VREncodeHandler.java

@@ -104,13 +104,14 @@ public class VREncodeHandler extends MessageToByteEncoder {
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-        if (PipelineUtil.containsCause(cause, CancelException.class)) return;
+        if (PipelineUtil.containsCause(cause, CancelException.class)) {
-        if (user.isActive()) {
+            if (user.isActive()) {
-            Iterator<Runnable> iterator = user.getPostProcessingTasks().iterator();
+                Runnable runnable;
-            while (iterator.hasNext()) {
+                while ((runnable = user.getPostProcessingTasks().poll()) != null) {
-                iterator.next().run();
+                    runnable.run();
-                iterator.remove();
+                }
             }
+            return;
         }
         super.exceptionCaught(ctx, cause);
     }
@@ -119,10 +120,9 @@ public class VREncodeHandler extends MessageToByteEncoder {
     public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
         super.write(ctx, msg, promise);
         if (user.isActive()) {
-            Iterator<Runnable> iterator = user.getPostProcessingTasks().iterator();
+            Runnable runnable;
-            while (iterator.hasNext()) {
+            while ((runnable = user.getPostProcessingTasks().poll()) != null) {
-                iterator.next().run();
+                runnable.run();
-                iterator.remove();
             }
         }
     }

src/main/java/com/github/creeper123123321/viarift/platform/VRUserConnection.java

@@ -88,7 +88,7 @@ public class VRUserConnection extends UserConnection {
 
     @Override
     public void sendRawPacketAfterProcessing(ByteBuf packet) {
-        ByteBuf copy = packet.alloc().buffer();
+        ByteBuf copy = Unpooled.buffer();
         try {
             Type.VAR_INT.write(copy, PacketWrapper.PASSTHROUGH_ID);
         } catch (Exception e) {