Class TaskClient

Namespace

Mabs.AudioCpp

Assembly

AudioCpp.dll

Generic framework tasks against POST /v1/tasks/run, /v1/tasks/stream and /v1/tasks/batch.

public sealed class TaskClient

Inheritance

object

TaskClient

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

BatchAsync(TaskBatchRequest, Func<TaskBatchEvent, Task>, CancellationToken)

Callback variant of BatchAsync(TaskBatchRequest, CancellationToken).

public Task BatchAsync(TaskBatchRequest request, Func<TaskBatchEvent, Task> onEvent, CancellationToken cancellationToken = default)

Parameters

request TaskBatchRequest

The batch request.

onEvent Func<TaskBatchEvent, Task>

Callback invoked for each event; iteration stops if it throws.

cancellationToken CancellationToken

Cancellation token.

Returns

Task

Completes when the stream terminates or the callback stops consuming events.

Exceptions

AudioCppException

The response failed or an SSE error event arrives.

BatchAsync(TaskBatchRequest, CancellationToken)

Native offline batch of generic requests. Results stream per entry (original request index preserved); per-result timing is null by design.

public IAsyncEnumerable<TaskBatchEvent> BatchAsync(TaskBatchRequest request, CancellationToken cancellationToken = default)

Parameters

request TaskBatchRequest

The batch request.

cancellationToken CancellationToken

Cancellation token observed while enumerating.

Returns

IAsyncEnumerable<TaskBatchEvent>

The event sequence; iteration ends at [DONE] or connection close.

Exceptions

AudioCppException

The response failed or an SSE error event arrives.

RunAsync(TaskRunRequest, CancellationToken)

Run one generic request.

public Task<TaskResult> RunAsync(TaskRunRequest request, CancellationToken cancellationToken = default)

Parameters

request TaskRunRequest

The run request.

cancellationToken CancellationToken

Cancellation token.

Returns

Task<TaskResult>

The task result.

Exceptions

AudioCppException

The request failed.

RunAsync(string, byte[], CancellationToken)

Run one generic request with inline audio bytes (Base64 form).

public Task<TaskResult> RunAsync(string model, byte[] audioBytes, CancellationToken cancellationToken = default)

Parameters

model string

The model id.

audioBytes byte[]

The audio bytes, Base64-encoded into the request body.

cancellationToken CancellationToken

Cancellation token.

Returns

Task<TaskResult>

The task result.

Exceptions

AudioCppException

The request failed.

StreamAsync(TaskStreamRequest, Func<TaskStreamEvent, Task>, CancellationToken)

Callback variant of StreamAsync(TaskStreamRequest, CancellationToken).

public Task StreamAsync(TaskStreamRequest request, Func<TaskStreamEvent, Task> onEvent, CancellationToken cancellationToken = default)

Parameters

request TaskStreamRequest

The stream request.

onEvent Func<TaskStreamEvent, Task>

Callback invoked for each event; iteration stops if it throws.

cancellationToken CancellationToken

Cancellation token.

Returns

Task

Completes when the stream terminates or the callback stops consuming events.

Exceptions

AudioCppException

The response failed or an SSE error event arrives.

StreamAsync(TaskStreamRequest, CancellationToken)

Stream one generic request. With StreamFormat = sse (default) events arrive as the model produces them; with null the server returns one buffered JSON body, which this method replays as the same event sequence. A run succeeded when Done arrives; mid-stream failures throw AudioCppException from the SSE error event.

public IAsyncEnumerable<TaskStreamEvent> StreamAsync(TaskStreamRequest request, CancellationToken cancellationToken = default)

Parameters

request TaskStreamRequest

The stream request.

cancellationToken CancellationToken

Cancellation token observed while enumerating.

Returns

IAsyncEnumerable<TaskStreamEvent>

The event sequence; iteration ends at [DONE] or connection close.

Exceptions

AudioCppException

The response failed or an SSE error event arrives.