diff options
author | Matthias Beyer <matthias.beyer@ifm.com> | 2022-04-28 10:08:29 +0200 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-04-28 10:12:17 +0200 |
commit | 2239dc16b1e9d228c976c6e30a5769969d16aea0 (patch) | |
tree | bfb87c18407e3697f23908e9246129b2afbf34d0 /plugins/plugin_measurement_filter/src | |
parent | b5724fefdbf443833c6467449bc79cc8e6b396f2 (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.rs | 5 |
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(()) } } - |