Cap the number of chunks written by StreamOutputRange.put at two.

vibe-d · Jun 26, 2017 · e1df68e · e1df68e
1 parent 321e4d8
commit e1df68e
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/stream/vibe/stream/wrapper.d b/stream/vibe/stream/wrapper.d
@@ -332,6 +332,13 @@ struct StreamOutputRange(OutputStream)
 
 	void put(const(ubyte)[] bts)
 	{
+		// avoid writing more chunks than necessary
+		if (bts.length + m_fill >= m_data.length * 2) {
+			flush();
+			m_stream.write(bts);
+			return;
+		}
+
 		while (bts.length) {
 			auto len = min(m_data.length - m_fill, bts.length);
 			m_data[m_fill .. m_fill + len] = bts[0 .. len];