@@ -49,15 +49,15 @@ use async_trait::async_trait;
49
49
/// # todo!()
50
50
/// # }
51
51
/// #
52
- /// # async fn receive(&self, topic: UUri) -> Result<UMessage, UStatus> {
52
+ /// # async fn receive(&self, source_filter: & UUri, sink_filter: Option<&UUri> ) -> Result<UMessage, UStatus> {
53
53
/// # todo!()
54
54
/// # }
55
55
/// #
56
- /// # async fn register_listener(&self, topic: UUri, listener: Arc<dyn UListener>) -> Result<(), UStatus> {
56
+ /// # async fn register_listener(&self, source_filter: & UUri, sink_filter: Option<&UUri> , listener: Arc<dyn UListener>) -> Result<(), UStatus> {
57
57
/// # Ok(())
58
58
/// # }
59
59
/// #
60
- /// # async fn unregister_listener(&self, topic: UUri, listener: Arc<dyn UListener>) -> Result<(), UStatus> {
60
+ /// # async fn unregister_listener(&self, source_filter: & UUri, sink_filter: Option<&UUri> , listener: Arc<dyn UListener>) -> Result<(), UStatus> {
61
61
/// # Ok(())
62
62
/// # }
63
63
/// # }
@@ -213,7 +213,7 @@ use async_trait::async_trait;
213
213
/// let subscription_response = usub.subscribe(subscription_request).await?;
214
214
/// let success_code = subscription_response.status.code.enum_value_or(UCode::UNKNOWN);
215
215
/// if success_code == UCode::OK {
216
- /// let register_success = up_client.register_listener(door_uuri.clone() , my_listener.clone()).await;
216
+ /// let register_success = up_client.register_listener(& door_uuri, None , my_listener.clone()).await;
217
217
/// } else {
218
218
/// match success_code {
219
219
/// UCode::NOT_FOUND => { /* handle topic not found */ }
@@ -227,7 +227,7 @@ use async_trait::async_trait;
227
227
/// ..Default::default()
228
228
/// };
229
229
/// let unsubscribe_result = usub.unsubscribe(unsubscribe_request).await?;
230
- /// let unregister_success = up_client.register_listener(door_uuri.clone() , my_listener.clone()).await;
230
+ /// let unregister_success = up_client.register_listener(& door_uuri, None , my_listener.clone()).await;
231
231
/// #
232
232
/// # Ok(())
233
233
/// # }
0 commit comments