(
&self,
messages: &[Message],
system: Option<&str>,
tools: &[ToolDefinition],
directive: &structured::StructuredDirective,
cancel_token: CancellationTo
| 98 | } |
| 99 | |
| 100 | async fn complete_streaming_structured( |
| 101 | &self, |
| 102 | messages: &[Message], |
| 103 | system: Option<&str>, |
| 104 | tools: &[ToolDefinition], |
| 105 | directive: &structured::StructuredDirective, |
| 106 | cancel_token: CancellationToken, |
| 107 | ) -> Result<mpsc::Receiver<StreamEvent>> { |
| 108 | self.0 |
| 109 | .complete_streaming_structured(messages, system, tools, directive, cancel_token) |
| 110 | .await |
| 111 | } |
| 112 | } |
no outgoing calls
no test coverage detected