pipe_box.hpp

Go to the documentation of this file.

/*
 * Copyright 2008,2009,2010,2011,2012 Stephan Ossowski, Korbinian Schneeberger,
 * Felix Ott, Joerg Hagmann, Alf Scotland, Sebastian Bender
 * 
 * This file is part of SHORE.
 * 
 * SHORE is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 * 
 * SHORE is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with SHORE.  If not, see <http://www.gnu.org/licenses/>.
 */


#ifndef SHORE_PROCESSING_PIPE_BOX_HPP__
#define SHORE_PROCESSING_PIPE_BOX_HPP__

#include <iostream>
#include <string>

#include "shore/processing/pipeline.hpp"
#include "shore/processing/feed.hpp"
#include "shore/processing/extractor.hpp"

namespace shore {

template<typename Pipe,
         typename S=typename source_traits<Pipe>::current_type,
         typename T=typename sink_traits<Pipe>::append_type>
class pipe_box
{
 public:

        typedef S current_type;
        typedef T append_type;
        typedef Pipe pipe_type;

 private:

        shore::feed<T> m_feed;
        shore::extractor<S> m_extractor;
        pipe_type m_pipe;

 public:

        pipe_box()
        {
                m_feed|m_pipe|m_extractor;
        }

        pipe_box(const pipe_box<Pipe,S,T> & other)
        :m_pipe(other.m_pipe)
        {
                m_feed|m_pipe|m_extractor;
        }

        template<typename Arg1>
        pipe_box(Arg1 arg1)
        :m_pipe(arg1)
        {
                m_feed|m_pipe|m_extractor;
        }

        template<typename Arg1,typename Arg2>
        pipe_box(Arg1 arg1,Arg2 arg2)
        :m_pipe(arg1,arg2)
        {
                m_feed|m_pipe|m_extractor;
        }

        pipe_type * operator->()
        {
                return &m_pipe;
        }

        pipe_type & operator*()
        {
                return m_pipe;
        }

        const current_type & current() const
        {
                return m_extractor.current();
        }

        bool has_data()
        {
                return m_extractor.has_data();
        }

        void next()
        {
                m_extractor.next();
        }

        void append(const append_type & d)
        {
                m_feed.append(d);
        }

        void flush()
        {
                m_feed.flush();
        }
};


} // namespace

#endif // SHORE_PROCESSING_PIPE_BOX_HPP__