Stream results with IAsyncEnumerable

Every streaming method on Engine returns IAsyncEnumerable<T>. Consume with await foreach. Disposing the enumerator (or the engine) completes the sequence.

Query result diffs

await foreach (var evt in drasi.QueryResultsAsync("open-orders"))
{
    foreach (var diff in evt.Results)
    {
        Console.WriteLine($"{diff.Type} {diff.Data}");
    }
}

QueryResultsAsync registers a hidden C# reaction named __stream_{queryId}_{guid} and removes it when the enumerator is disposed. Pass reactionId if you need a stable name.

This is the same payload a callback reaction receives (QueryResultEvent). Prefer a reaction when the handler should outlive a single loop. Prefer QueryResultsAsync when the consumer is a loop, a channel, or ASP.NET endpoint code.

Lifecycle events

await foreach (var evt in drasi.QueryEventsAsync("open-orders"))
{
    Console.WriteLine($"{evt.ComponentId} -> {evt.Status}");
}

ComponentStatus values include Added, Starting, Running, Stopping, Stopped, Removed, Reconfiguring, and Error.

Logs

await foreach (var line in drasi.QueryLogsAsync("open-orders"))
{
    Console.WriteLine($"{line.Level} {line.Message}");
}

SourceLogsAsync and ReactionLogsAsync do the same for those components. Plugin log lines show up here too.

Backpressure

Each subscription uses a 256-item buffer. If the consumer is slower than the producer and the buffer fills, the stream throws StreamLaggedException (STREAM_LAGGED). Native callbacks never block on the consumer.

Honor CancellationToken on the enumerable. Every *Async method also takes a token. Cancellation is cooperative: the native call runs on Task.Run.