rust-fsm

Finite state machines in rust; bendns fork to add types.

Clone

HTTPS

SSH

Diffstat (limited to 'rust_fsm/examples/circuit_breaker_dsl.rs')

-rw-r--r--

1 files changed, 4 insertions, 3 deletions

diff --git a/rust_fsm/examples/circuit_breaker_dsl.rs b/rust_fsm/examples/circuit_breaker_dsl.rs
index 6a22aab..04b2e03 100644
--- a/rust_fsm/examples/circuit_breaker_dsl.rs
+++ b/rust_fsm/examples/circuit_breaker_dsl.rs

@@ -6,6 +6,7 @@ extern crate rust_fsm_dsl;

use rust_fsm::*;

use std::sync::{Arc, Mutex};

+use std::time::Duration;

state_machine! {

CircuitBreaker(Closed)

@@ -31,7 +32,7 @@ fn main() {

// Set up a timer

let machine_wait = machine.clone();

std::thread::spawn(move || {

- std::thread::sleep_ms(5000);

+ std::thread::sleep(Duration::new(5, 0));

let mut lock = machine_wait.lock().unwrap();

let res = lock.consume_anyway(&CircuitBreakerInput::TimerTriggered);

assert_eq!(res, None);

@@ -41,7 +42,7 @@ fn main() {

// Try to pass a request when the circuit breaker is still open

let machine_try = machine.clone();

std::thread::spawn(move || {

- std::thread::sleep_ms(1000);

+ std::thread::sleep(Duration::new(1, 0));

let mut lock = machine_try.lock().unwrap();

let res = lock.consume_anyway(&CircuitBreakerInput::Successful);

assert_eq!(res, None);

@@ -49,7 +50,7 @@ fn main() {

});

// Test if the circit breaker was actually closed

- std::thread::sleep_ms(7000);

+ std::thread::sleep(Duration::new(7, 0));

{

let mut lock = machine.lock().unwrap();

let res = lock.consume_anyway(&CircuitBreakerInput::Successful);