()
| 39 | |
| 40 | #[test] |
| 41 | fn collector_flush_partial() { |
| 42 | let mut c = TriggerBatchCollector::new(100); |
| 43 | c.push("t", "INSERT", 1, row("a")); |
| 44 | c.push("t", "INSERT", 1, row("b")); |
| 45 | let batch = c.flush().unwrap(); |
| 46 | assert_eq!(batch.rows.len(), 2); |
| 47 | assert!(!c.has_pending()); |
| 48 | } |
| 49 | |
| 50 | #[test] |
| 51 | fn collector_flushes_on_collection_change() { |