]> git.sesse.net Git - casparcg/blobdiff - core/consumer/output.cpp
2.0. ogl_consumer: Refactored
[casparcg] / core / consumer / output.cpp
index ad8d51003a58f5f1fa969f83b0558999b73ed50b..fce751112bad59671f656f4563f77b262b5df331 100644 (file)
@@ -90,10 +90,15 @@ public:
        \r
        void add(int index, safe_ptr<frame_consumer>&& consumer)\r
        {               \r
-               consumer->initialize(channel_.get_format_desc());\r
                channel_.execution().invoke([&]\r
                {\r
                        consumers_.erase(index);\r
+               });\r
+\r
+               consumer->initialize(channel_.get_format_desc());\r
+\r
+               channel_.execution().invoke([&]\r
+               {\r
                        consumers_.insert(std::make_pair(index, consumer));\r
 \r
                        CASPAR_LOG(info) << print() << L" " << consumer->print() << L" Added.";\r