diff --git a/src/main/java/org/spacehq/packetlib/tcp/TcpClientSession.java b/src/main/java/org/spacehq/packetlib/tcp/TcpClientSession.java
index 8dd72527..3971d8e4 100644
--- a/src/main/java/org/spacehq/packetlib/tcp/TcpClientSession.java
+++ b/src/main/java/org/spacehq/packetlib/tcp/TcpClientSession.java
@@ -104,6 +104,7 @@ public class TcpClientSession extends TcpSession {
                         });
                     } catch(Throwable t) {
                         complete.set(true);
+                        exceptionCaught(null, t);
                     }
                 }
             }).start();