StreamController.hpp

// <StreamController> -*- C++ -*-
 
#pragma once
 
namespace sparta {
namespace statistics {
 
class StreamController
{
public:
    virtual ~StreamController() {}
 
    void startStreaming() {
        if (!is_streaming_) {
            startStreaming_();
            is_streaming_ = true;
        }
    }
 
    void processStreams() {
        if (!is_streaming_) {
            startStreaming_();
        }
        processStreams_();
    }
 
    void stopStreaming() {
        if (is_streaming_) {
            processStreams_();
            stopStreaming_();
            is_streaming_ = false;
        }
    }
 
private:
    bool is_streaming_ = false;
 
    virtual void startStreaming_() = 0;
    virtual void processStreams_() = 0;
    virtual void stopStreaming_() = 0;
};
 
} // namespace statistics
} // namespace sparta