diff --git a/src/stream_interface.c b/src/stream_interface.c
index 017d1ef31..ca138cbef 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -626,6 +626,9 @@ int si_cs_send(struct conn_stream *cs)
 
 		if (conn->flags & CO_FL_ERROR || cs->flags & CS_FL_ERROR)
 			return 1;
+
+		if (oc->pipe)
+			goto end;
 	}
 
 	/* At this point, the pipe is empty, but we may still have data pending