X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=core%2Fconsumer%2Fframe_consumer.h;h=58ffeb61b62168581d4f2d91c4f2ea5d068c9897;hb=9e4b08cde6c6de9e83a3fff42d90affc3cd8e5bc;hp=e09e4edcfe263f8a36c5a22359b831fe3fab445b;hpb=b59ec2b89fbc8a2fbccaaa42d623db97a241a54b;p=casparcg diff --git a/core/consumer/frame_consumer.h b/core/consumer/frame_consumer.h index e09e4edcf..58ffeb61b 100644 --- a/core/consumer/frame_consumer.h +++ b/core/consumer/frame_consumer.h @@ -44,19 +44,19 @@ class frame_consumer public: // Static Members - + static const spl::shared_ptr& empty(); // Constructors frame_consumer(){} virtual ~frame_consumer() {} - + // Methods virtual std::future send(const_frame frame) = 0; virtual void initialize(const video_format_desc& format_desc, const audio_channel_layout& channel_layout, int channel_index) = 0; - + // monitor::observable virtual monitor::subject& monitor_output() = 0; @@ -70,14 +70,17 @@ public: virtual int buffer_depth() const = 0; // -1 to not participate in frame presentation synchronization virtual int index() const = 0; virtual int64_t presentation_frame_age_millis() const = 0; + virtual const frame_consumer* unwrapped() const { return this; } }; typedef std::function( const std::vector&, - interaction_sink* sink)> consumer_factory_t; + interaction_sink* sink, + std::vector> channels)> consumer_factory_t; typedef std::function( const boost::property_tree::wptree& element, - interaction_sink* sink)> preconfigured_consumer_factory_t; + interaction_sink* sink, + std::vector> channels)> preconfigured_consumer_factory_t; class frame_consumer_registry : boost::noncopyable { @@ -89,11 +92,13 @@ public: const preconfigured_consumer_factory_t& factory); spl::shared_ptr create_consumer( const std::vector& params, - interaction_sink* sink) const; + interaction_sink* sink, + std::vector> channels) const; spl::shared_ptr create_consumer( const std::wstring& element_name, const boost::property_tree::wptree& element, - interaction_sink* sink) const; + interaction_sink* sink, + std::vector> channels) const; private: struct impl; spl::shared_ptr impl_;