\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