diff --git a/rust-toolchain.toml b/rust-toolchain.toml index 7eb23c42..7897a24d 100644 --- a/rust-toolchain.toml +++ b/rust-toolchain.toml @@ -1,2 +1,2 @@ [toolchain] -channel = "1.72.1" +channel = "1.75.0" diff --git a/zenoh-flow-descriptors/src/flattened/mod.rs b/zenoh-flow-descriptors/src/flattened/mod.rs index e798ad38..932ad3b2 100644 --- a/zenoh-flow-descriptors/src/flattened/mod.rs +++ b/zenoh-flow-descriptors/src/flattened/mod.rs @@ -25,13 +25,6 @@ use std::{ use zenoh_flow_commons::NodeId; -pub use self::{ - dataflow::FlattenedDataFlowDescriptor, - nodes::{ - operator::FlattenedOperatorDescriptor, sink::FlattenedSinkDescriptor, - source::FlattenedSourceDescriptor, - }, -}; use crate::{ nodes::operator::composite::{CompositeInputDescriptor, CompositeOutputDescriptor}, InputDescriptor, LinkDescriptor, OutputDescriptor, diff --git a/zenoh-flow-nodes/src/io/outputs.rs b/zenoh-flow-nodes/src/io/outputs.rs index a55b1189..8253bc5b 100644 --- a/zenoh-flow-nodes/src/io/outputs.rs +++ b/zenoh-flow-nodes/src/io/outputs.rs @@ -56,7 +56,7 @@ impl Outputs { /// Insert the `flume::Sender` in the [Outputs], creating the entry if needed in the internal /// `HashMap`. pub fn insert(&mut self, port_id: PortId, tx: Sender) { - self.hmap.entry(port_id).or_insert_with(Vec::new).push(tx) + self.hmap.entry(port_id).or_default().push(tx) } /// Returns an Output builder for the provided `port_id`, if an output was declared with this exact name in the diff --git a/zenoh-flow-records/src/dataflow.rs b/zenoh-flow-records/src/dataflow.rs index feee7a20..9425b674 100644 --- a/zenoh-flow-records/src/dataflow.rs +++ b/zenoh-flow-records/src/dataflow.rs @@ -208,7 +208,7 @@ Caused by: ); additional_mappings .entry(runtime_from.clone()) - .or_insert_with(HashSet::default) + .or_default() .insert(sender_id); receivers.insert( @@ -220,7 +220,7 @@ Caused by: ); additional_mappings .entry(runtime_to.clone()) - .or_insert_with(HashSet::default) + .or_default() .insert(receiver_id); } }