()
| 466 | |
| 467 | #[test] |
| 468 | fn streaming_encoder_matches_batch() { |
| 469 | let values: Vec<i64> = (0..1000).map(|i| 1_000_000 + i * 100).collect(); |
| 470 | let batch_encoded = encode(&values); |
| 471 | |
| 472 | let mut enc = DoubleDeltaEncoder::new(); |
| 473 | for &v in &values { |
| 474 | enc.push(v); |
| 475 | } |
| 476 | let stream_encoded = enc.finish(); |
| 477 | |
| 478 | assert_eq!(batch_encoded, stream_encoded); |
| 479 | } |
| 480 | |
| 481 | #[test] |
| 482 | fn streaming_decoder() { |