()
| 376 | |
| 377 | #[test] |
| 378 | fn response_ok() { |
| 379 | let resp = Response { |
| 380 | request_id: RequestId::new(1), |
| 381 | status: Status::Ok, |
| 382 | attempt: 1, |
| 383 | partial: false, |
| 384 | payload: Payload::from_vec(b"result".to_vec()), |
| 385 | watermark_lsn: Lsn::new(42), |
| 386 | error_code: None, |
| 387 | }; |
| 388 | assert_eq!(resp.status, Status::Ok); |
| 389 | assert_eq!(resp.watermark_lsn, Lsn::new(42)); |
| 390 | assert_eq!(&*resp.payload, b"result"); |
| 391 | } |
| 392 | |
| 393 | #[test] |
| 394 | fn response_error() { |