(&self)
| 276 | } |
| 277 | |
| 278 | pub(super) fn fan_out_params(&self) -> FanOutParams { |
| 279 | FanOutParams { |
| 280 | shard_ids: self.params.shard_ids.clone(), |
| 281 | timeout_ms: self.params.timeout_ms, |
| 282 | source_node: self.params.source_node, |
| 283 | } |
| 284 | } |
| 285 | } |
| 286 | |
| 287 | /// Deserialise a slice of raw `(shard_id, bytes)` pairs into typed responses. |
no test coverage detected