tets

Author: stevenwdv

Rx/v2/src/rxcpp/operators/rx-concat_map.hpp

@@ -115,6 +115,8 @@ struct concat_map
         collection_selector_type selectCollection;
         result_selector_type selectResult;
         coordination_type coordination;
+    private:
+        values& operator=(const values&) RXCPP_DELETE;
     };
     values initial;
 
@@ -273,6 +275,8 @@ struct concat_map
         source->subscribe(std::move(selectedSink.get()));
 
     }
+private:
+    concat_map& operator=(const concat_map&) RXCPP_DELETE;
 };
 
 }

Rx/v2/src/rxcpp/operators/rx-reduce.hpp

@@ -124,6 +124,9 @@ struct reduce : public operator_base<rxu::value_type_t<reduce_traits<T, Observab
         accumulator_type accumulator;
         result_selector_type result_selector;
         seed_type seed;
+
+    private:
+        reduce_initial_type& operator=(reduce_initial_type o) RXCPP_DELETE;
     };
     reduce_initial_type initial;
 
@@ -178,6 +181,8 @@ struct reduce : public operator_base<rxu::value_type_t<reduce_traits<T, Observab
             }
         );
     }
+private:
+    reduce& operator=(reduce o) RXCPP_DELETE;
 };
 
 template<class T>

Rx/v2/src/rxcpp/operators/rx-subscribe_on.hpp

@@ -59,6 +59,8 @@ struct subscribe_on : public operator_base<T>
         }
         source_type source;
         coordination_type coordination;
+    private:
+        subscribe_on_values& operator=(subscribe_on_values o) RXCPP_DELETE;
     };
     const subscribe_on_values initial;
 
@@ -85,6 +87,8 @@ struct subscribe_on : public operator_base<T>
             }
             composite_subscription source_lifetime;
             output_type out;
+        private:
+            subscribe_on_state_type& operator=(subscribe_on_state_type o) RXCPP_DELETE;
         };
 
         composite_subscription coordinator_lifetime;
@@ -134,6 +138,8 @@ struct subscribe_on : public operator_base<T>
 
         controller.schedule(selectedProducer.get());
     }
+private:
+    subscribe_on& operator=(subscribe_on o) RXCPP_DELETE;
 };
 
 }