| 261 | } |
| 262 | |
| 263 | fn do_no_check_stop_test(code: &str) { |
| 264 | let (tx, rx) = async_channel::unbounded(); |
| 265 | let mut machine = MachineBuilder::default().with_signals_chan((tx.clone(), rx)).build(); |
| 266 | |
| 267 | block_on(tx.send(Signal::Break)).unwrap(); |
| 268 | |
| 269 | machine.compile(&mut code.as_bytes()).unwrap(); |
| 270 | match block_on(machine.exec()) { |
| 271 | Ok(None) => (), |
| 272 | r => panic!("Expected Ok(None) but got {:?}", r), |
| 273 | } |
| 274 | |
| 275 | assert_eq!(1, tx.len()); |
| 276 | } |
| 277 | |
| 278 | fn do_check_stop_test(code: &str) { |
| 279 | let (tx, rx) = async_channel::unbounded(); |