1 files changed, 234 insertions, 0 deletions

diff --git a/src/stable/streamstack.cpp b/src/stable/streamstack.cpp
new file mode 100644
index 0000000..d45306d
--- /dev/null
+++ b/src/stable/streamstack.cpp
@@ -0,0 +1,234 @@
+/*
+ * Copyright (C) 2007-2011 Xagasoft, All rights reserved.
+ *
+ * This file is part of the libbu++ library and is released under the
+ * terms of the license contained in the file LICENSE.
+ */
+
+#include "bu/streamstack.h"
+
+Bu::StreamStack::StreamStack()
+{
+}
+
+Bu::StreamStack::StreamStack( Bu::Stream *pStream )
+{
+        lFilts.prepend( pStream );
+}
+
+Bu::StreamStack::~StreamStack()
+{
+        clear();
+}
+
+bool Bu::StreamStack::isEmpty()
+{
+        return lFilts.isEmpty();
+}
+
+bool Bu::StreamStack::hasStream()
+{
+        return !lFilts.isEmpty();
+}
+
+void Bu::StreamStack::setStream( Bu::Stream *pStream )
+{
+        if( !lFilts.isEmpty() )
+                throw Bu::ExceptionBase("There is already a stream set.");
+
+        lFilts.prepend( pStream );
+}
+
+void Bu::StreamStack::clear()
+{
+        for( FilterList::iterator i = lFilts.begin(); i; i++ )
+        {
+                delete *i;
+        }
+
+        lFilts.clear();
+}
+
+void Bu::StreamStack::popFilter()
+{
+        if( lFilts.isEmpty() )
+                return;
+
+        delete lFilts.first();
+        lFilts.erase( lFilts.begin() );
+}
+
+Bu::Stream *Bu::StreamStack::getTop()
+{
+        checkStack();
+
+        return lFilts.first();
+}
+
+Bu::Stream *Bu::StreamStack::getStream()
+{
+        checkStack();
+
+        return lFilts.last();
+}
+
+void Bu::StreamStack::close()
+{
+        checkStack();
+
+        lFilts.first()->close();
+}
+
+Bu::size Bu::StreamStack::read( void *pBuf, Bu::size nBytes )
+{
+        checkStack();
+
+        return lFilts.first()->read( pBuf, nBytes );
+}
+
+Bu::size Bu::StreamStack::write( const void *pBuf, Bu::size nBytes )
+{
+        checkStack();
+
+        return lFilts.first()->write( pBuf, nBytes );
+}
+
+Bu::size Bu::StreamStack::write( const Bu::String &sBuf )
+{
+        checkStack();
+
+        return lFilts.first()->write( sBuf );
+}
+
+Bu::size Bu::StreamStack::tell()
+{
+        checkStack();
+
+        return lFilts.first()->tell();
+}
+
+void Bu::StreamStack::seek( Bu::size offset )
+{
+        checkStack();
+
+        lFilts.first()->seek( offset );
+}
+
+void Bu::StreamStack::setPos( Bu::size pos )
+{
+        checkStack();
+
+        lFilts.first()->setPos( pos );
+}
+
+void Bu::StreamStack::setPosEnd( Bu::size pos )
+{
+        checkStack();
+
+        lFilts.first()->setPosEnd( pos );
+}
+
+bool Bu::StreamStack::isEos()
+{
+        checkStack();
+
+        return lFilts.first()->isEos();
+}
+
+bool Bu::StreamStack::isOpen()
+{
+        checkStack();
+
+        return lFilts.first()->isOpen();
+}
+
+void Bu::StreamStack::flush()
+{
+        checkStack();
+
+        lFilts.first()->flush();
+}
+
+bool Bu::StreamStack::canRead()
+{
+        checkStack();
+
+        return lFilts.first()->canRead();
+}
+
+bool Bu::StreamStack::canWrite()
+{
+        checkStack();
+
+        return lFilts.first()->canWrite();
+}
+
+bool Bu::StreamStack::isReadable()
+{
+        checkStack();
+
+        return lFilts.first()->isReadable();
+}
+
+bool Bu::StreamStack::isWritable()
+{
+        checkStack();
+
+        return lFilts.first()->isWritable();
+}
+
+bool Bu::StreamStack::isSeekable()
+{
+        checkStack();
+
+        return lFilts.first()->isSeekable();
+}
+
+bool Bu::StreamStack::isBlocking()
+{
+        checkStack();
+
+        return lFilts.first()->isBlocking();
+}
+
+void Bu::StreamStack::setBlocking( bool bBlocking )
+{
+        checkStack();
+
+        lFilts.first()->setBlocking( bBlocking );
+}
+
+void Bu::StreamStack::setSize( Bu::size iSize )
+{
+        checkStack();
+
+        lFilts.first()->setSize( iSize );
+}
+
+Bu::size Bu::StreamStack::getSize() const
+{
+        checkStack();
+        
+        return lFilts.first()->getSize();
+}
+
+Bu::size Bu::StreamStack::getBlockSize() const
+{
+        checkStack();
+
+        return lFilts.first()->getBlockSize();
+}
+
+Bu::String Bu::StreamStack::getLocation() const
+{
+        checkStack();
+
+        return lFilts.first()->getLocation();
+}
+
+inline void Bu::StreamStack::checkStack() const
+{
+        if( lFilts.isEmpty() )
+                throw Bu::ExceptionBase("StreamStack is empty.");
+}
+