Merged asynchronous invocation of consumers from 2.0

[casparcg] / core / consumer / frame_consumer.h

diff --git a/core/consumer/frame_consumer.h b/core/consumer/frame_consumer.h
index 9fe65434339b9a22246c11b7fc5eaed6d48c3063..9288b2a487094070c35701d6bbb121e808bccfb7 100644 (file)
--- a/core/consumer/frame_consumer.h
+++ b/core/consumer/frame_consumer.h
@@ -26,13 +26,14 @@
 #include <common/memory.h>
 
 #include <boost/property_tree/ptree_fwd.hpp>
+#include <boost/thread/future.hpp>
 
 #include <functional>
 #include <string>
 #include <vector>
 
 namespace caspar { namespace core {
-       
+
 // Interface
 class frame_consumer : public monitor::observable
 {
@@ -51,7 +52,7 @@ public:
        
        // Methods
 
-       virtual bool                                                    send(class const_frame frame) = 0;
+       virtual boost::unique_future<bool>              send(class const_frame frame) = 0;
        virtual void                                                    initialize(const struct video_format_desc& format_desc, int channel_index) = 0;
        
        // monitor::observable