aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/config.rs7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/config.rs b/src/config.rs
index 97b438f..2ba10ec 100644
--- a/src/config.rs
+++ b/src/config.rs
@@ -351,6 +351,7 @@ mod tests {
Program::new(vec!["/bin/program2", "arg"]),
Program::new(vec!["/bin/program3", "arg"]),
]
+ .into()
);
assert_eq!(route_map.qos, Some(QoS::ExactlyOnce));
@@ -361,6 +362,7 @@ mod tests {
Program::new(vec!["/bin/program4", "arg"]),
Program::new_with_timeout(vec!["/bin/program5"], Duration::from_secs_f64(1.2)),
]
+ .into()
);
assert_eq!(route_seq.qos, None);
}
@@ -394,6 +396,7 @@ mod tests {
Program::new(vec!["/foo/bar"]),
Program::new(vec!["/baz/qux", "arg"])
]
+ .into()
);
assert_eq!(route.qos, None);
}
@@ -411,14 +414,14 @@ mod tests {
let route_with_qos = config.routes.get("topic/with_qos").unwrap();
assert_eq!(
route_with_qos.programs,
- vec![Program::new(vec!["/foo/bar", "arg"])]
+ vec![Program::new(vec!["/foo/bar", "arg"])].into()
);
assert_eq!(route_with_qos.qos, Some(QoS::AtLeastOnce));
let route_without_qos = config.routes.get("topic/without_qos").unwrap();
assert_eq!(
route_without_qos.programs,
- vec![Program::new(vec!["/baz/qux"])]
+ vec![Program::new(vec!["/baz/qux"])].into()
);
assert_eq!(route_without_qos.qos, None);
}