diff --git a/src/runtime/mod.rs b/src/runtime/mod.rs index b5f63c8958d8bc0e79d923734538dbd57c1ba0f8..c1acf7cc7637f20dce218a1a06d9bf0ed1e60447 100644 --- a/src/runtime/mod.rs +++ b/src/runtime/mod.rs @@ -51,7 +51,13 @@ pub enum SetupMsg { LeaderWave { wave_leader: ConnectorId }, LeaderAnnounce { tree_leader: ConnectorId }, YouAreMyParent, + SessionGather { unoptimized_map: HashMap }, + SessionScatter { optimized_map: HashMap }, } + +#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)] +pub struct SessionInfo {} + #[derive(Clone, Debug, serde::Serialize, serde::Deserialize)] pub struct CommMsg { pub round_index: usize, @@ -192,7 +198,7 @@ pub struct SyncProtoContext<'a> { } //////////////// impl VecSet { - fn iter(&self) -> impl Iterator { + fn iter(&self) -> std::slice::Iter { self.vec.iter() } fn contains(&self, element: &T) -> bool {