diff --git a/crates/crank-runtime/src/executor.rs b/crates/crank-runtime/src/executor.rs index d18ef8e..22025ec 100644 --- a/crates/crank-runtime/src/executor.rs +++ b/crates/crank-runtime/src/executor.rs @@ -617,9 +617,9 @@ mod tests { assert_eq!(result.items.len(), 3); assert_eq!(result.items[0], json!({ "seq": 1, "value": 101 })); assert_eq!(result.items[2], json!({ "seq": 3, "value": 103 })); - assert!(result.window_complete); - assert!(!result.truncated); - assert!(!result.has_more); + assert!(!result.window_complete); + assert!(result.truncated); + assert!(result.has_more); } #[tokio::test] @@ -844,6 +844,7 @@ mod tests { json!({ "seq": 1, "value": 101 }), json!({ "seq": 2, "value": 102 }), json!({ "seq": 3, "value": 103 }), + json!({ "seq": 4, "value": 104 }), ] { sink.send(tokio_tungstenite::tungstenite::Message::Text( payload.to_string().into(),