()
| 480 | |
| 481 | #[test] |
| 482 | fn streaming_decoder() { |
| 483 | let values: Vec<i64> = (0..100).map(|i| 5000 + i * 10).collect(); |
| 484 | let encoded = encode(&values); |
| 485 | let mut dec = DoubleDeltaDecoder::new(&encoded).unwrap(); |
| 486 | |
| 487 | for &expected in &values { |
| 488 | assert_eq!(dec.next_value(), Some(expected)); |
| 489 | } |
| 490 | assert_eq!(dec.next_value(), None); |
| 491 | assert_eq!(dec.remaining(), 0); |
| 492 | } |
| 493 | |
| 494 | #[test] |
| 495 | fn truncated_input_errors() { |