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