Adapter mapping marianoguerra/llm streaming events onto MoonStream sessions.
Dependencies
let adapter = @llm_mb_adapter.LlmMbAdapter::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 LlmMbAdapter::apply(self : LlmMbAdapter, event : StreamEvent) -> AdapterOutcome raise SessionErrorfn LlmMbAdapter::finish_call(self : LlmMbAdapter, content_index : Int, reason~ : EndReason) -> (Array[Event], FinishResult) raise SessionErrorInstall
Download zipAdapter mapping marianoguerra/llm streaming events onto MoonStream sessions.
Dependencies