From 39e23f7a98222a9e5bbb8baeefc6dd0ab98a4f42 Mon Sep 17 00:00:00 2001 From: Kai Hudalla Date: Wed, 8 May 2024 15:26:01 +0200 Subject: [PATCH] Fix USubscription doc tests The doc tests had not been updated yet to reflect the changes introduced to the UTransport trait's functions for matching on source and sink address patterns. --- src/core/usubscription.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/core/usubscription.rs b/src/core/usubscription.rs index 99d5a79b..1eda7176 100644 --- a/src/core/usubscription.rs +++ b/src/core/usubscription.rs @@ -49,15 +49,15 @@ use async_trait::async_trait; /// # todo!() /// # } /// # -/// # async fn receive(&self, topic: UUri) -> Result { +/// # async fn receive(&self, source_filter: &UUri, sink_filter: Option<&UUri>) -> Result { /// # todo!() /// # } /// # -/// # async fn register_listener(&self, topic: UUri, listener: Arc) -> Result<(), UStatus> { +/// # async fn register_listener(&self, source_filter: &UUri, sink_filter: Option<&UUri>, listener: Arc) -> Result<(), UStatus> { /// # Ok(()) /// # } /// # -/// # async fn unregister_listener(&self, topic: UUri, listener: Arc) -> Result<(), UStatus> { +/// # async fn unregister_listener(&self, source_filter: &UUri, sink_filter: Option<&UUri>, listener: Arc) -> Result<(), UStatus> { /// # Ok(()) /// # } /// # } @@ -213,7 +213,7 @@ use async_trait::async_trait; /// let subscription_response = usub.subscribe(subscription_request).await?; /// let success_code = subscription_response.status.code.enum_value_or(UCode::UNKNOWN); /// if success_code == UCode::OK { -/// let register_success = up_client.register_listener(door_uuri.clone(), my_listener.clone()).await; +/// let register_success = up_client.register_listener(&door_uuri, None, my_listener.clone()).await; /// } else { /// match success_code { /// UCode::NOT_FOUND => { /* handle topic not found */ } @@ -227,7 +227,7 @@ use async_trait::async_trait; /// ..Default::default() /// }; /// let unsubscribe_result = usub.unsubscribe(unsubscribe_request).await?; -/// let unregister_success = up_client.register_listener(door_uuri.clone(), my_listener.clone()).await; +/// let unregister_success = up_client.register_listener(&door_uuri, None, my_listener.clone()).await; /// # /// # Ok(()) /// # }