diff --git a/lib/base/stream.cpp b/lib/base/stream.cpp
index 72ca82c1a..3048f096c 100644
--- a/lib/base/stream.cpp
+++ b/lib/base/stream.cpp
@@ -91,6 +91,16 @@ bool Stream::WaitForData(int timeout)
 	return IsDataAvailable() || IsEof();
 }
 
+void Stream::SetCorked(bool corked)
+{
+	m_Corked = corked;
+}
+
+bool Stream::IsCorked() const
+{
+	return m_Corked;
+}
+
 static void StreamDummyCallback()
 { }
 
diff --git a/lib/base/stream.hpp b/lib/base/stream.hpp
index 8a140a586..bb4129138 100644
--- a/lib/base/stream.hpp
+++ b/lib/base/stream.hpp
@@ -127,6 +127,9 @@ public:
 	bool WaitForData();
 	bool WaitForData(int timeout);
 
+	virtual void SetCorked(bool corked);
+	bool IsCorked() const;
+
 	virtual bool SupportsWaiting() const;
 
 	virtual bool IsDataAvailable() const;
@@ -143,6 +146,8 @@ private:
 
 	boost::mutex m_Mutex;
 	boost::condition_variable m_CV;
+
+	bool m_Corked{false};
 };
 
 }