diff --git a/src/stream_interface.c b/src/stream_interface.c
index e37d0b9..0669546 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -1360,6 +1360,13 @@
 		}
 
 		if (ret <= 0) {
+			/* if we refrained from reading because we asked for a
+			 * flush to satisfy rcv_pipe(), we must not subscribe
+			 * and instead report that there's not enough room
+			 * here to proceed.
+			 */
+			if (flags & CO_RFL_BUF_FLUSH)
+				si_rx_room_blk(si);
 			break;
 		}