Added 'inputStreamSocketAdapter' and 'stopSequenceFilteredInputStream'.

1 files changed, 38 insertions, 2 deletions

diff --git a/src/utility/stream.cpp b/src/utility/stream.cpp
index 3899eb52..94be1447 100644
--- a/src/utility/stream.cpp
+++ b/src/utility/stream.cpp
@@ -319,11 +319,11 @@ const stream::size_type inputStreamPointerAdapter::skip(const size_type count)
 }
 
 
-// outputStreamSocketAdapter
-
 #ifdef VMIME_HAVE_MESSAGING_FEATURES
 
 
+// outputStreamSocketAdapter
+
 outputStreamSocketAdapter::outputStreamSocketAdapter(messaging::socket& sok)
 	: m_socket(sok)
 {
@@ -337,6 +337,42 @@ void outputStreamSocketAdapter::write
 }
 
 
+// inputStreamSocketAdapter
+
+inputStreamSocketAdapter::inputStreamSocketAdapter(messaging::socket& sok)
+	: m_socket(sok)
+{
+}
+
+
+const bool inputStreamSocketAdapter::eof() const
+{
+	// Can't know...
+	return false;
+}
+
+
+void inputStreamSocketAdapter::reset()
+{
+	// Not supported
+}
+
+
+const stream::size_type inputStreamSocketAdapter::read
+	(value_type* const data, const size_type count)
+{
+	return m_socket.receiveRaw(data, count);
+}
+
+
+const stream::size_type inputStreamSocketAdapter::skip
+	(const size_type /* count */)
+{
+	// Not supported
+	return 0;
+}
+
+
 #endif // VMIME_HAVE_MESSAGING_FEATURES