DeepSeek Kotlin SDK/org.oremif.deepseek.client/DeepSeekClientStream

DeepSeekClientStream

class DeepSeekClientStream : DeepSeekClientBase

Client for streaming interactions with the DeepSeek API.

This client specializes in handling streaming responses for real-time processing of DeepSeek API outputs, particularly useful for chat completions.

Types

Builder

class Builder(token: String? = null) : DeepSeekClientBase.Builder

Builder for configuring and creating DeepSeekClientStream instances.

Properties

client

val client: HttpClient

The underlying HTTP client used for API requests

config

val config: DeepSeekClientConfig

Configuration options for the DeepSeek client

Functions

chat

suspend fun DeepSeekClientStream.chat(blockMessage: ChatCompletionRequest.MessageBuilder.() -> Unit): Flow<ChatCompletionChunk>

Streams chat responses using default parameters and a message builder DSL.

suspend fun DeepSeekClientStream.chat(message: String): Flow<ChatCompletionChunk>

Streams chat responses for a single user message.

suspend fun DeepSeekClientStream.chat(messages: List<ChatMessage>): Flow<ChatCompletionChunk>

Streams chat responses using default parameters.

suspend fun DeepSeekClientStream.chat(params: ChatCompletionParams, blockMessage: ChatCompletionRequest.MessageBuilder.() -> Unit): Flow<ChatCompletionChunk>

Streams chat responses using custom parameters and a message builder DSL.

suspend fun DeepSeekClientStream.chat(params: ChatCompletionParams, messages: List<ChatMessage>): Flow<ChatCompletionChunk>

Streams chat responses using custom parameters and messages.

chatCompletion

suspend fun DeepSeekClientBase.chatCompletion(request: ChatCompletionRequest): ChatCompletion

Sends a chat completion request to the DeepSeek API.

suspend fun DeepSeekClientStream.chatCompletion(block: ChatCompletionRequest.StreamBuilder.() -> Unit): Flow<ChatCompletionChunk>

Streams a fully customizable chat completion request.

chatCompletionStream

suspend fun DeepSeekClientBase.chatCompletionStream(request: ChatCompletionRequest): Flow<ChatCompletionChunk>

Streams chat completion responses chunk by chunk from the DeepSeek API.

open override fun close()

Closes the underlying HTTP client and releases resources.

fim

suspend fun DeepSeekClientStream.fim(prompt: String): Flow<FIMCompletion>

Streams FIM completions with default parameters.

suspend fun DeepSeekClientStream.fim(params: FIMCompletionParams, prompt: String): Flow<FIMCompletion>

Streams FIM completions using custom parameters and a prompt.

fimCompletion

suspend fun DeepSeekClientBase.fimCompletion(request: FIMCompletionRequest): FIMCompletion

Sends a Fill-In-the-Middle (FIM) completion request to the DeepSeek API.

suspend fun DeepSeekClientStream.fimCompletion(block: FIMCompletionRequest.StreamBuilder.() -> Unit): Flow<FIMCompletion>

Streams a fully customizable FIM completion using a builder pattern.

fimCompletionStream

suspend fun DeepSeekClientBase.fimCompletionStream(request: FIMCompletionRequest): Flow<FIMCompletion>

Streams Fill-In-the-Middle (FIM) completions chunk by chunk from the DeepSeek API.

models

suspend fun DeepSeekClientBase.models(): ListsModels

Retrieves the list of available DeepSeek AI models.

userBalance

suspend fun DeepSeekClientBase.userBalance(): UserBalance

Retrieves the current user's available API credits and usage information.