Adapter mapping mizchi/llm streaming events onto MoonStream sessions.
Dependencies
ToolCallStart(id~ : String, name~ : String)
ToolCallDelta(id~ : String, input_delta~ : String)
ToolCallEnd(id~ : String, name~ : String, input~ : Json)let adapter = @mizchi_llm_adapter.MizchiLlmAdapter::new(response_id="resp-1")
for event in stream_events {
match adapter.apply(event) {
@adapter.AdapterOutcome::Ignored => ()
@adapter.AdapterOutcome::Updates(updates~) =>
for update in 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 MizchiLlmAdapter::apply(self : MizchiLlmAdapter, event : StreamEvent) -> AdapterOutcome raise SessionErrorfn MizchiLlmAdapter::finish_slot(self : MizchiLlmAdapter, slot : Int, reason~ : EndReason) -> (Array[Event], FinishResult) raise SessionErrorInstall
Download zipAdapter mapping mizchi/llm streaming events onto MoonStream sessions.
Dependencies