Method WriteAsync

Namespace

Qavren.Edge.Ingestion.DataIngestion

Assembly

Qavren.Edge.Ingestion.DataIngestion.dll

WriteAsync(IAsyncEnumerable<IngestionChunk<string>>, CancellationToken)

Writes chunks asynchronously.

public override Task WriteAsync(IAsyncEnumerable<IngestionChunk<string>> chunks, CancellationToken cancellationToken = default)

Parameters

chunks IAsyncEnumerable<IngestionChunk<string>>

The chunks to write.

cancellationToken CancellationToken

The token to monitor for cancellation requests.

Returns

Task

A task representing the asynchronous write operation.