diff --git a/src/stream_interface.c b/src/stream_interface.c
index 1a6db19..8415abb 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -501,6 +501,12 @@
 	if (conn->flags & CO_FL_ERROR)
 		si->flags |= SI_FL_ERR;
 
+	/* check for recent connection establishment */
+	if (!(conn->flags & (CO_FL_WAIT_L4_CONN | CO_FL_CONNECTED))) {
+		si->exp = TICK_ETERNITY;
+		si->ob->flags |= BF_WRITE_NULL;
+	}
+
 	/* process consumer side, only once if possible */
 	if (fdtab[fd].ev & (FD_POLL_OUT | FD_POLL_ERR)) {
 		if (si->ob->flags & BF_OUT_EMPTY) {