pub fn create_streamer(
rx: Receiver<Response>,
state: SharedMistralRsState,
on_chunk: Option<ChatCompletionOnChunkCallback>,
on_done: Option<ChatCompletionOnDoneCallback>,
) -> Sse<KeepAliveStream<ChatCompletionStreamer>>Expand description
Creates a SSE streamer for chat completions with optional callbacks.