Adapter mapping DC-Z-lab/moonllm streaming chunks onto MoonStream sessions.
Dependencies
let adapter = @moonllm_adapter.MoonllmAdapter::new(response_id="chatcmpl-1")
for chunk in chunks {
for update in adapter.apply(chunk).updates() {
render(update.key, update.events)
match update.failure {
Some(error) => report_error(update.key, error)
None => ()
}
match update.result {
Some(result) => deliver(update.key, result)
None => ()
}
}
}fn MoonllmAdapter::apply(self : MoonllmAdapter, chunk : StreamChunk) -> AdapterOutcome raise SessionErrorfn MoonllmAdapter::finish_call(self : MoonllmAdapter, index : Int, reason~ : EndReason) -> (Array[Event], FinishResult) raise SessionErrorInstall
Download zipAdapter mapping DC-Z-lab/moonllm streaming chunks onto MoonStream sessions.
Dependencies