Completes the connection emitter so that the thread blocked in establishWebSocketClient() returns immediately instead of waiting for the connect timeo

Release startLatch and stopLatch to unblock any waiting threads.

app completion call for http request by sse stream @param param app completion params @return flowable stream of app completion result @throws ApiExc

Call the server to get the result by stream. @param param The input param of class `CodeGenerationParam`. @return A `Flowable` of the output structur

Submit tool outputs, and return stream result. @param threadId The thread id. @param runId The run id. @param param The output parameters. @return Th

Upload file to OSS with optional certificate reuse. @param model Model name @param filePath Local file path @param apiKey API key @param certificate

send audio in base64 format @param audioBase64 base64 audio string

Call the server to get the result in the callback function. @param param The input param of class `GenerationParam`. @param callback The callback to

Call the server to get the whole result. @param param The input param of class `ConversationParam`. @return The output structure of `QWenConversation

Call the server to get the whole result. @param param The input param of class `ImageGenerationParam`. @return The output structure of `ImageGenerati

Call the server to get the result. @param param The input param of class `VideoSynthesisParam`. @return The video synthesis result. @throws NoApiKeyE

Clears accumulated data for the current thread. Should be called when streaming is complete or encounters error.

Clears accumulated data for the current thread. Should be called when streaming is complete or encounters error.

Clears accumulated data for the current thread. Should be called when streaming is complete or encounters error.

Connect to server, create session and return default session configuration

create response, use audio and video commited before to request llm. When in Server VAD mode, the client does not need to use this method, the server

Add an SSE "data" line.

Replays the parked terminal error, if any, to the currently attached subscriber.

First Package Delay is the time between start sending audio and receive first words package

First Package Delay is the time between start sending audio and receive first words package

First Package Delay is the time between start sending text and receive first audio package

Last Package Delay is the time between stop sending audio and receive last words package

Last Package Delay is the time between stop sending audio and receive last words package

Check if the model is qwen{n} where n is greater than or equal to 3 @param modelName the model name to check @return true if model is qwen{n} where n

Creates a new audio format config, convenience factory method equivalent to {@code new OmniRealtimeAudioFormatConfig(type, sampleRate)}. @param type

Requests response. <p>param: type Response type param: text Response text param: updateParams Update parameters

Check if the increment_output parameter should be modified for the given model @param modelName the model name to check @return false if model contai

Call the server to get the result by stream. @param param The input param of class `ConversationParam`. @return A `Flowable` of the output structure.

Update session configuration, should be used before create response @param config session configuration

Wait for async task completed and return task result. @param taskId The async task id. @param apiKey The api-key. @param baseUrl The base http url. @

@param param The async embedding request parameter, class `AsyncTextEmbeddingParam` @return The async task information of `AsyncTextEmbeddingResult` @

Async call @param param The input param of class VideoSynthesisParam @return The video synthesis result. @throws NoApiKeyException Can not find api k