Function test_break_stops_after_upcall

std/src/exec.rs:188–214

()

    #[test]
    fn test_break_stops_after_upcall() {
        let (tx, rx) = async_channel::unbounded();
        let break_tx = tx.clone();
        let datetime = Rc::from(MockDateTime::default());
        datetime.set_sleep_fn(Box::new(
            move |_d: Duration| -> futures_lite::future::BoxedLocal<Result<(), String>> {
                let break_tx = break_tx.clone();
                async move {
                    break_tx.send(Signal::Break).await.unwrap();
                    Ok(())
                }
                .boxed_local()
            },
        ));

        let mut machine = MachineBuilder::default()
            .with_signals_chan((tx.clone(), rx))
            .with_datetime(datetime)
            .build();
        machine.compile(&mut "DO: SLEEP 0: LOOP".as_bytes()).unwrap();

        match block_on(machine.exec()) {
            Err(Error::Break) => (),
            r => panic!("Expected Break but got {:?}", r),
        }
        assert_eq!(0, tx.len());
    }

    #[test]
    fn test_yielder_called_on_stop_reason_yield() {