Fix #31: RxROS operators should use subscribe_on rather than observe_on

rosin-project · Oct 7, 2019 · 6218d6e · 6218d6e
1 parent 024a92b
commit 6218d6e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/rxros/include/rxros/rxros.h b/rxros/include/rxros/rxros.h
@@ -301,7 +301,7 @@ namespace rxros
         auto publish_to_topic(const std::string &topic, const uint32_t queue_size = 10) {
             return [=](auto&& source) {
                 ros::Publisher publisher(rxros::node::get_handle().advertise<T>(topic, queue_size));
-                source.observe_on(rxcpp::synchronize_new_thread()).subscribe(
+                source.subscribe_on(rxcpp::synchronize_new_thread()).subscribe(
                     [=](const T& msg) {publisher.publish(msg);});
                 return source;};}
 

diff --git a/rxros_tf/include/rxros_tf/rxros_tf.h b/rxros_tf/include/rxros_tf/rxros_tf.h
@@ -77,15 +77,15 @@ namespace rxros
         auto send_transform() {
             return [=](auto&& source) {
                 tf::TransformBroadcaster transformBroadcaster;
-                source.observe_on(rxcpp::synchronize_new_thread()).subscribe(
+                source.subscribe_on(rxcpp::synchronize_new_thread()).subscribe(
                     [&](const tf::StampedTransform& stf) {transformBroadcaster.sendTransform(stf);});
                 return source;};}
 
 
         auto send_transform(const std::string &parent_frameId, const std::string &child_frameId) {
             return [=](auto&& source) {
                 tf::TransformBroadcaster transformBroadcaster;
-                source.observe_on(rxcpp::synchronize_new_thread()).subscribe(
+                source.subscribe_on(rxcpp::synchronize_new_thread()).subscribe(
                     [&](const tf::Transform& tf) {transformBroadcaster.sendTransform(tf::StampedTransform(tf, ros::Time::now(), parent_frameId, child_frameId));});
                 return source;};}