Skip to content

Commit

Permalink
update tests
Browse files Browse the repository at this point in the history
  • Loading branch information
galenseilis committed Oct 6, 2024
1 parent 53a3c73 commit a8e960d
Showing 1 changed file with 8 additions and 12 deletions.
20 changes: 8 additions & 12 deletions desru/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@
//!
//! fn main() {
//! let mut scheduler = EventScheduler::new();
//! let action = Box::new(|| {
//! println!("Event executed!");
//! Some("Event completed.".to_string())
//! });
//!
//! let event = Event::new(5.0, Some(action), None);
//! let mut event = Event::new(0.0, Some(Box::new(|scheduler| Some("Executed".to_string()))), None);
//! scheduler.schedule(event);
//! scheduler.run_until_max_time(10.0);
//! }
Expand Down Expand Up @@ -170,10 +165,11 @@ impl Event {
///
/// # Example
/// ```
/// use desru::{Event};
/// use desru::{Event, EventScheduler};
///
/// let mut event = Event::new(0.0, Some(Box::new(|| Some("Executed".to_string()))), None);
/// assert_eq!(event.run(), Some("Executed".to_string()));
/// let mut scheduler = EventScheduler::new();
/// let mut event = Event::new(0.0, Some(Box::new(|scheduler| Some("Executed".to_string()))), None);
/// assert_eq!(event.run(&mut scheduler), Some("Executed".to_string()));
/// ```
pub fn run(&mut self, scheduler: &mut EventScheduler) -> Option<String> {
if self.active {
Expand Down Expand Up @@ -283,7 +279,7 @@ impl EventScheduler {
/// use desru::EventScheduler;
///
/// let mut scheduler = EventScheduler::new();
/// scheduler.timeout(10.0, Some(Box::new(|| Some("Timeout event".to_string()))), None);
/// scheduler.timeout(10.0, Some(Box::new(|_| Some("Timeout event".to_string()))), None);
/// ```
pub fn timeout(&mut self, delay: f64, action: Option<Box<dyn FnMut(&mut EventScheduler) -> Option<String>>>, context: Option<HashMap<String, String>>) {
let event = Event::new(self.current_time + delay, action, context);
Expand All @@ -304,7 +300,7 @@ impl EventScheduler {
/// use desru::{Event, EventScheduler};
///
/// let mut scheduler = EventScheduler::new();
/// scheduler.timeout(5.0, Some(Box::new(|| Some("Event executed".to_string()))), None);
/// scheduler.timeout(5.0, Some(Box::new(|_| Some("Event executed".to_string()))), None);
/// let stop_fn = Box::new(|s: &EventScheduler| s.current_time >= 10.0);
/// scheduler.run(stop_fn, None);
/// ```
Expand Down Expand Up @@ -339,7 +335,7 @@ impl EventScheduler {
/// use desru::{Event, EventScheduler};
///
/// let mut scheduler = EventScheduler::new();
/// scheduler.timeout(5.0, Some(Box::new(|| Some("Timeout event".to_string()))), None);
/// scheduler.timeout(5.0, Some(Box::new(|_| Some("Timeout event".to_string()))), None);
/// scheduler.run_until_max_time(10.0);
/// ```
pub fn run_until_max_time(&mut self, max_time: f64) -> Vec<(Event, Option<String>)> {
Expand Down

0 comments on commit a8e960d

Please sign in to comment.