Merged asynchronous invocation of consumers from 2.0

[casparcg] / core / consumer / port.cpp

diff --git a/core/consumer/port.cpp b/core/consumer/port.cpp
index ca2b063dd0a90bacd1fad794b82d433ef005459c..652690cb45aa4d883b5b3c5ce8ba8d2d3dab4382 100644 (file)
--- a/core/consumer/port.cpp
+++ b/core/consumer/port.cpp
@@ -28,7 +28,7 @@ public:
                consumer_->initialize(format_desc, channel_index_);
        }
                
-       bool send(const_frame frame)
+       boost::unique_future<bool> send(const_frame frame)
        {
                event_subject_ << monitor::event("type") % consumer_->name();
                return consumer_->send(std::move(frame));
@@ -59,7 +59,7 @@ port::port(int index, int channel_index, spl::shared_ptr<frame_consumer> consume
 port::port(port&& other) : impl_(std::move(other.impl_)){}
 port::~port(){}
 port& port::operator=(port&& other){impl_ = std::move(other.impl_); return *this;}
-bool port::send(const_frame frame){return impl_->send(std::move(frame));}      
+boost::unique_future<bool> port::send(const_frame frame){return impl_->send(std::move(frame));}        
 void port::subscribe(const monitor::observable::observer_ptr& o){impl_->event_subject_.subscribe(o);}
 void port::unsubscribe(const monitor::observable::observer_ptr& o){impl_->event_subject_.unsubscribe(o);}
 void port::video_format_desc(const struct video_format_desc& format_desc){impl_->video_format_desc(format_desc);}