(id: u64, data: &str)
| 125 | } |
| 126 | |
| 127 | fn make_partial(id: u64, data: &str) -> Response { |
| 128 | Response { |
| 129 | request_id: RequestId::new(id), |
| 130 | status: Status::Partial, |
| 131 | attempt: 1, |
| 132 | partial: true, |
| 133 | payload: Payload::from_vec(data.as_bytes().to_vec()), |
| 134 | watermark_lsn: Lsn::ZERO, |
| 135 | error_code: None, |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | #[tokio::test] |
| 140 | async fn register_and_complete() { |