Merge scheduler

[czajah]

Hi, I have few questions

1. Do I need to add scheduler to merge operator in this code? When do I have to provide it and why?

   auto src1 = rxcpp::sources::interval(std::chrono::seconds(1), rxcpp::observe_on_new_thread())
   .map([](auto i){
   return "1# i: " + std::to_string(i);
   });

   auto src2 = rxcpp::sources::interval(std::chrono::milliseconds(500), rxcpp::observe_on_new_thread())
   .map([](auto i){
   return "2# i: " + std::to_string(i);
   });

   src1
   .merge(src2)
   .subscribe([](auto s){
   std::cout << s << std::endl;
   });

2. Can I do something like this if I want to have only one thread instead of two (or three in case if I have to create anothed one for merge operator)?

   auto sc = rxcpp::schedulers::make_new_thread();
   auto w = sc.create_worker();
   auto so = rxcpp::identity_same_worker(w);

   auto src1 = rxcpp::sources::interval(std::chrono::seconds(1), so)
   .map([](auto i){
   return "1# i: " + std::to_string(i);
   });

   auto src2 = rxcpp::sources::interval(std::chrono::milliseconds(500), so)
   .map([](auto i){
   return "2# i: " + std::to_string(i);
   });

   src1
   .merge(src2)
   .subscribe([](auto s){
   std::cout << s << std::endl;
   });