| 5 | |
| 6 | #[rt::test] |
| 7 | async fn test_error() -> Result<()> { |
| 8 | let mut graph = Builder::default() |
| 9 | .template( |
| 10 | r#" |
| 11 | main="test" |
| 12 | [[graphs]] |
| 13 | name="sub" |
| 14 | nodes=[ |
| 15 | {name="a", ty="Transform"}, |
| 16 | {name="b", ty="ErrorOpr"}, |
| 17 | {name="c", ty="Transform"} |
| 18 | ] |
| 19 | inputs=[{name="inp",cap=1,ports=["a:inp"]}] |
| 20 | outputs=[{name="out",cap=1,ports=["c:out"]}] |
| 21 | connections=[ |
| 22 | {cap=1,ports=["a:out", "b:inp"]}, |
| 23 | {cap=1,ports=["b:out", "c:inp"]} |
| 24 | ] |
| 25 | [[graphs]] |
| 26 | name="test" |
| 27 | nodes=[ |
| 28 | {name="a", ty="NeverOpr"}, |
| 29 | {name="b", ty="sub"}, |
| 30 | {name="c", ty="NoopConsumer"}, |
| 31 | ] |
| 32 | connections=[ |
| 33 | {cap=1,ports=["a:out", "b:inp"]}, |
| 34 | {cap=1,ports=["b:out", "c:inp"]} |
| 35 | ] |
| 36 | "# |
| 37 | .to_owned(), |
| 38 | ) |
| 39 | .build()?; |
| 40 | assert!(graph.start().await.is_err()); |
| 41 | Ok(()) |
| 42 | } |
| 43 | |
| 44 | #[rt::test] |
| 45 | async fn test_basis() -> Result<()> { |