InputStream.hpp

Go to the documentation of this file.

/*
 *  InputStream.h
 *  ers
 *
 *  Created by Serguei Kolos on 02.08.05.
 *  Copyright 2004 CERN. All rights reserved.
 *
 */
 
#ifndef ERS_INPUT_STREAM_H
#define ERS_INPUT_STREAM_H
 
#include <string>
#include <ers/Issue.hpp>
#include <ers/IssueReceiver.hpp>
 
namespace ers {
    class Issue;
 
    class InputStream {
        friend class StreamManager;
 
    public:
        virtual ~InputStream() {
            ;
        }
 
    protected:
        InputStream();
 
        void receive(const Issue &issue);
 
    private:
        InputStream(const InputStream &other) = delete;
        InputStream& operator=(const InputStream&) = delete;
 
        void set_receiver(IssueReceiver *receiver) {
            m_receiver = receiver;
        }
 
        IssueReceiver *m_receiver;
    };
}
 
#include <ers/StreamFactory.hpp>
 
#define ERS_REGISTER_INPUT_STREAM( class, name, params ) \
namespace { \
    struct InputStreamRegistrator { \
    static ers::InputStream * create( const std::initializer_list<std::string> & params ) \
    { return new class( params ); }  \
        InputStreamRegistrator() \
    { ers::StreamFactory::instance().register_in_stream( name, create ); } \
    } registrator_mp; \
}
 
#endif