diff --git a/src/stream_interface.c b/src/stream_interface.c
index 0afcb97..2677b2f 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -1189,7 +1189,7 @@
 			break;
 		}
 
-		ret = conn->mux->rcv_buf(cs, ic->buf, max, 0);
+		ret = conn->mux->rcv_buf(cs, ic->buf, max, co_data(ic) ? CO_RFL_BUF_WET : 0);
 		if (cs->flags & CS_FL_RCV_MORE)
 			si->flags |= SI_FL_WAIT_ROOM;