Rename MessageSource::add_sink to connect_sink

Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>

Author: didier-wenzek

crates/core/tedge_actors/src/builders.rs

@@ -183,7 +183,7 @@ pub trait MessageSource<M: Message, Config> {
     fn register_peer(&mut self, config: Config, sender: DynSender<M>);
 
     /// Connect a peer actor that will consume the message produced by this actor
-    fn add_sink(&mut self, config: Config, peer: &impl MessageSink<M>) {
+    fn connect_sink(&mut self, config: Config, peer: &impl MessageSink<M>) {
         self.register_peer(config, peer.get_sender());
     }
 }

crates/core/tedge_actors/src/converter.rs

@@ -216,7 +216,7 @@ impl<C: Converter> ConvertingActor<C> {
 ///     converter_builder.connect_source(TopicFilter("some/mqtt/topics/#"), &mut mqtt_builder);
 ///
 ///     // Connect the same mqtt actor as a sink of this actor, to send output messages to it
-///     converter_builder.add_sink(NoConfig, &mut mqtt_builder);
+///     converter_builder.connect_sink(NoConfig, &mut mqtt_builder);
 ///
 ///     // Finally build the actor
 ///     converter_builder.build()

crates/core/tedge_agent/src/agent.rs

@@ -437,7 +437,7 @@ pub fn create_tedge_to_te_converter(
         ConvertingActor::builder("TedgetoTeConverter", tedge_to_te_converter);
 
     tedge_converter_actor.connect_source(subscriptions, mqtt_actor_builder);
-    tedge_converter_actor.add_sink(NoConfig, mqtt_actor_builder);
+    tedge_converter_actor.connect_sink(NoConfig, mqtt_actor_builder);
 
     Ok(tedge_converter_actor)
 }

crates/extensions/c8y_mapper_ext/src/compatibility_adapter.rs

@@ -43,7 +43,7 @@ impl OldAgentAdapter {
     ) -> ConvertingActorBuilder<OldAgentAdapter> {
         let mut builder = ConvertingActor::builder("OldAgentAdapter", OldAgentAdapter);
         builder.connect_source(old_and_new_command_topics(), mqtt);
-        builder.add_sink(NoConfig, mqtt);
+        builder.connect_sink(NoConfig, mqtt);
         builder
     }
 }

crates/extensions/tedge_signal_ext/src/lib.rs

@@ -58,7 +58,7 @@ pub struct SignalActor {
 impl SignalActor {
     pub fn builder(runtime: &impl MessageSink<RuntimeAction>) -> SignalActorBuilder {
         let mut box_builder = SimpleMessageBoxBuilder::new("Signal-Handler", 1);
-        box_builder.add_sink(NoConfig, runtime);
+        box_builder.connect_sink(NoConfig, runtime);
         SignalActorBuilder { box_builder }
     }
 }