diff --git a/src/mux_pt.c b/src/mux_pt.c
index 5a80848..1f0f3e5 100644
--- a/src/mux_pt.c
+++ b/src/mux_pt.c
@@ -142,6 +142,7 @@
 	struct conn_stream *cs;
 	struct mux_pt_ctx *ctx = conn->mux_ctx;
 
+	conn->xprt->unsubscribe(conn, SUB_CAN_RECV, &ctx->wait_event);
 	cs = cs_new(conn);
 	if (!cs)
 		goto fail;