diff --git a/r2r/examples/action_client.rs b/r2r/examples/action_client.rs index 9d47c6105..94243d569 100644 --- a/r2r/examples/action_client.rs +++ b/r2r/examples/action_client.rs @@ -10,7 +10,7 @@ fn main() -> Result<(), Box> { let ctx = r2r::Context::create()?; let mut node = r2r::Node::create(ctx, "testnode", "")?; let client = node.create_action_client::("/fibonacci")?; - let action_server_available = node.is_available(&client)?; + let action_server_available = r2r::Node::is_available(&client)?; // signal that we are done let done = Arc::new(Mutex::new(false)); diff --git a/r2r/examples/action_client_untyped.rs b/r2r/examples/action_client_untyped.rs index 198a3426e..a649717d8 100644 --- a/r2r/examples/action_client_untyped.rs +++ b/r2r/examples/action_client_untyped.rs @@ -13,7 +13,7 @@ fn main() -> Result<(), Box> { let mut node = r2r::Node::create(ctx, "testnode", "")?; let client = node.create_action_client_untyped("/fibonacci", "example_interfaces/action/Fibonacci")?; - let action_server_available = node.is_available(&client)?; + let action_server_available = r2r::Node::is_available(&client)?; // signal that we are done let done = Arc::new(Mutex::new(false)); diff --git a/r2r/examples/client.rs b/r2r/examples/client.rs index 7b1469487..1b073212e 100644 --- a/r2r/examples/client.rs +++ b/r2r/examples/client.rs @@ -33,7 +33,7 @@ fn main() -> Result<(), Box> { let mut node = r2r::Node::create(ctx, "testnode", "")?; let client = node.create_client::("/add_two_ints")?; - let service_available = node.is_available(&client)?; + let service_available = r2r::Node::is_available(&client)?; let mut pool = LocalPool::new(); let spawner = pool.spawner(); diff --git a/r2r/examples/service.rs b/r2r/examples/service.rs index abb4499e1..ab5feb8c1 100644 --- a/r2r/examples/service.rs +++ b/r2r/examples/service.rs @@ -22,7 +22,7 @@ fn main() -> Result<(), Box> { let mut timer = node.create_wall_timer(std::time::Duration::from_millis(250))?; let mut timer2 = node.create_wall_timer(std::time::Duration::from_millis(2000))?; // wait for service to be available - let service_available = node.is_available(&client)?; + let service_available = r2r::Node::is_available(&client)?; let mut pool = LocalPool::new(); let spawner = pool.spawner(); diff --git a/r2r/examples/tokio_client.rs b/r2r/examples/tokio_client.rs index f24c48f2b..522a94874 100644 --- a/r2r/examples/tokio_client.rs +++ b/r2r/examples/tokio_client.rs @@ -7,7 +7,7 @@ async fn main() -> Result<(), Box> { use r2r::example_interfaces::srv::AddTwoInts; let client = node.create_client::("/add_two_ints")?; let mut timer = node.create_wall_timer(duration)?; - let waiting = node.is_available(&client)?; + let waiting = r2r::Node::is_available(&client)?; let handle = tokio::task::spawn_blocking(move || loop { node.spin_once(std::time::Duration::from_millis(100)); diff --git a/r2r/examples/tokio_examples.rs b/r2r/examples/tokio_examples.rs index 9ed84f97d..798d0b5e5 100644 --- a/r2r/examples/tokio_examples.rs +++ b/r2r/examples/tokio_examples.rs @@ -78,7 +78,7 @@ async fn client(arc_node: Arc>) -> Result<(), r2r::Error> { let mut node = arc_node.lock().unwrap(); let client = node.create_client::("/add_two_ints")?; let timer = node.create_wall_timer(std::time::Duration::from_secs(2))?; - let service_available = node.is_available(&client)?; + let service_available = r2r::Node::is_available(&client)?; (client, timer, service_available) }; println!("waiting for service..."); diff --git a/r2r/examples/untyped_client.rs b/r2r/examples/untyped_client.rs index 20df39a11..b5c04845c 100644 --- a/r2r/examples/untyped_client.rs +++ b/r2r/examples/untyped_client.rs @@ -29,7 +29,7 @@ fn main() -> Result<(), Box> { let client = node.create_client_untyped("/add_two_ints", "example_interfaces/srv/AddTwoInts")?; - let service_available = node.is_available(&client)?; + let service_available = r2r::Node::is_available(&client)?; let mut pool = LocalPool::new(); let spawner = pool.spawner(); diff --git a/r2r/src/nodes.rs b/r2r/src/nodes.rs index 8058fda5e..5ffb8bc46 100644 --- a/r2r/src/nodes.rs +++ b/r2r/src/nodes.rs @@ -707,7 +707,7 @@ impl Node { /// `spin_once` until available, so spin_once must be called /// repeatedly in order to get the wakeup. pub fn is_available( - &mut self, client: &dyn IsAvailablePollable, + client: &dyn IsAvailablePollable, ) -> Result>> { let (sender, receiver) = oneshot::channel(); client.register_poll_available(sender)?;