diff --git a/src/stream.c b/src/stream.c
index d425836..6916cad 100644
--- a/src/stream.c
+++ b/src/stream.c
@@ -120,7 +120,7 @@ static int stream__flush_plain(struct stream* self)
 			break;
 	}
 
-	if (n_msgs < 0)
+	if (n_msgs == 0)
 		return 0;
 
 	bytes_sent = writev(self->fd, iov, n_msgs);