output_p.h

#ifndef OUTPUT_P_H
#define OUTPUT_P_H

#include <functional>
#include <mutex>
#include <list>
#include "streams/stream_object.h"

class InputPrivate;

class ROVIZ_EXPORT OutputPrivate
{
public:
    typedef std::list<std::function<void (StreamObject)> >::const_iterator Connection;

    std::list<std::function<void (StreamObject)> > pushInFuncs;
    std::list<InputPrivate*> connected_inputs;

    OutputPrivate() = default;
    ~OutputPrivate();

    Connection connect(InputPrivate *in, std::function<void (StreamObject)> fn);

    void disconnect(InputPrivate *in, Connection conn);

private:
    std::mutex mtx;
};

#endif // OUTPUT_P_H