diff --git a/transport/src/test/java/io/netty/channel/local/LocalChannelTest.java b/transport/src/test/java/io/netty/channel/local/LocalChannelTest.java
index 628f621f4e..bbba9c52f7 100644
--- a/transport/src/test/java/io/netty/channel/local/LocalChannelTest.java
+++ b/transport/src/test/java/io/netty/channel/local/LocalChannelTest.java
@@ -1190,8 +1190,16 @@ public class LocalChannelTest {
                 } else {
                     read = 0;
                 }
+            } else {
+                read = 0;
             }
             ctx.fireChannelReadComplete();
         }
+
+        @Override
+        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+            ctx.fireExceptionCaught(cause);
+            ctx.close();
+        }
     }
 }