diff --git a/src/stream.c b/src/stream.c
index 6a6166eea..14060b2e9 100644
--- a/src/stream.c
+++ b/src/stream.c
@@ -2292,6 +2292,13 @@ struct task *process_stream(struct task *t, void *context, unsigned int state)
 				    (s->be->mode == PR_MODE_HTTP) &&
 				    !(s->txn->flags & TX_D_L7_RETRY))
 					s->txn->flags |= TX_L7_RETRY;
+
+				if (s->be->options & PR_O_ABRT_CLOSE) {
+					struct connection *conn = sc_conn(scf);
+
+					if (conn)
+						conn->mux->ctl(conn, MUX_SUBS_RECV, NULL);
+				}
 			}
 		}
 		else {