AI SDK Kotlin/ai.torad.aisdk.ui/UiMessageStreams

UiMessageStreams

object UiMessageStreams(source)

Since

0.3.0-beta01

Functions

getResponseUiMessageId

fun getResponseUiMessageId(messages: List<UIMessage>, createId: () -> String = { "msg_${messages.size + 1}" }): String

handleUiMessageStreamFinish

fun handleUiMessageStreamFinish(messages: List<UIMessage>, onFinish: (List<UIMessage>) -> Unit)

lastAssistantMessageIsCompleteWithApprovalResponses

fun lastAssistantMessageIsCompleteWithApprovalResponses(messages: List<UIMessage>): Boolean

lastAssistantMessageIsCompleteWithToolCalls

fun lastAssistantMessageIsCompleteWithToolCalls(messages: List<UIMessage>): Boolean

pipeTextStreamToResponse

suspend fun pipeTextStreamToResponse(textStream: Flow<String>, response: ServerResponseWriter, status: Int = 200, headers: Map<String, String> = textStreamHeaders())

pipeUiMessageStreamToResponse

suspend fun pipeUiMessageStreamToResponse(stream: Flow<UIMessage>, response: ServerResponseWriter, encoder: (UIMessage) -> String = { "data: ${aiSdkOutputJson.encodeToString(it)}\n\n" }, status: Int = 200, headers: Map<String, String> = uiMessageStreamHeaders())

safeValidateUIMessages

fun safeValidateUIMessages(messages: List<UIMessage>?): SafeValidateUIMessagesResult

textStreamHeaders

fun textStreamHeaders(): Map<String, String>

uiMessageStreamHeaders

fun uiMessageStreamHeaders(): Map<String, String>

validateUIMessages

fun validateUIMessages(messages: List<UIMessage>)

validateUiMessages

fun validateUiMessages(messages: List<UIMessage>)