(
&self,
messages: Vec<Json>,
kind: LocalRailKind,
)
| 317 | } |
| 318 | |
| 319 | async fn check( |
| 320 | &self, |
| 321 | messages: Vec<Json>, |
| 322 | kind: LocalRailKind, |
| 323 | ) -> FlowResult<LocalCheckOutcome> { |
| 324 | let result = self |
| 325 | .worker |
| 326 | .request(json!({ |
| 327 | "command": "check", |
| 328 | "messages": messages, |
| 329 | "rail_type": kind.as_str(), |
| 330 | })) |
| 331 | .await?; |
| 332 | parse_check_result(result) |
| 333 | } |
| 334 | |
| 335 | async fn has_streaming_output_rails(&self) -> FlowResult<bool> { |
| 336 | let result = self |
no test coverage detected