From acf4d0cb44ee25f65b98f12e6599307f3c4bb6d0 Mon Sep 17 00:00:00 2001 From: haixuanTao Date: Wed, 4 Dec 2024 16:18:57 +0100 Subject: [PATCH] Fix typo --- apis/rust/node/src/event_stream/scheduler.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apis/rust/node/src/event_stream/scheduler.rs b/apis/rust/node/src/event_stream/scheduler.rs index 8c2434a7..27a4d460 100644 --- a/apis/rust/node/src/event_stream/scheduler.rs +++ b/apis/rust/node/src/event_stream/scheduler.rs @@ -64,7 +64,7 @@ impl Scheduler { } pub fn next(&mut self) -> Option { - // Retreive message from the non input event first that have priority over input messaage. + // Retrieve message from the non input event first that have priority over input message. if let Some((_size, queue)) = self .event_queues .get_mut(&DataId::from(NON_INPUT_EVENT.to_string())) @@ -74,7 +74,7 @@ impl Scheduler { } } - // Process the ID with the oldest timestamp using BTreMap Ordering + // Process the ID with the oldest timestamp using BTreeMap Ordering for (index, id) in self.last_used.clone().iter().enumerate() { if let Some((_size, queue)) = self.event_queues.get_mut(id) { if let Some(event) = queue.pop_front() {