summaryrefslogtreecommitdiffstats
path: root/plugins/plugin_measurement_filter/src
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@ifm.com>2022-04-28 10:08:29 +0200
committerMatthias Beyer <matthias.beyer@ifm.com>2022-04-28 10:12:17 +0200
commit2239dc16b1e9d228c976c6e30a5769969d16aea0 (patch)
treebfb87c18407e3697f23908e9246129b2afbf34d0 /plugins/plugin_measurement_filter/src
parentb5724fefdbf443833c6467449bc79cc8e6b396f2 (diff)
plugin_measurement_filter: Adapt for new Address::send_* interfaces
In commit 86530000d17d0727d20423fae01226201c2a1aa5 ("Rename send to send_and_wait") we renamed `Address:send()` to `Address::send_and_wait()` for a clearer interface design. This patch fixes the implementation of the plugin_measurement_filter crate to match this new interface. Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
Diffstat (limited to 'plugins/plugin_measurement_filter/src')
-rw-r--r--plugins/plugin_measurement_filter/src/plugin.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/plugins/plugin_measurement_filter/src/plugin.rs b/plugins/plugin_measurement_filter/src/plugin.rs
index 02a4f396..4ea951e3 100644
--- a/plugins/plugin_measurement_filter/src/plugin.rs
+++ b/plugins/plugin_measurement_filter/src/plugin.rs
@@ -66,14 +66,13 @@ impl Handle<Measurement> for MeasurementFilterPlugin {
if let Some(value) = message.extract(&self.extractor.0) {
trace!("Applying filter {:?} to value {:?}", self.filter, value);
if value.apply_filter(&self.filter) {
- let _ = self.target.send(message).await;
+ let _ = self.target.send_and_wait(message).await;
} else {
if let Some(ftarget) = self.filtered_target.as_ref() {
- let _ = ftarget.send(message).await;
+ let _ = ftarget.send_and_wait(message).await;
}
}
}
Ok(())
}
}
-