Interface IContinuousQuerySource<T>

Namespace

Apache.Ignite.Table

Assembly

Apache.Ignite.dll

Represents an object which can be queried continuously.

public interface IContinuousQuerySource<T>

Type Parameters

T

Data type.

Methods

QueryContinuouslyAsync(ContinuousQueryOptions?, CancellationToken)

Starts a continuous query which listens to data events within the underlying table and returns an infinite IAsyncEnumerable<T> of batched events.

The query will be stopped when the IAsyncEnumerator<T> returned from GetAsyncEnumerator(CancellationToken) call is disposed. This happens automatically when you break out of the await foreach loop or use System.Linq.Async methods.

IAsyncEnumerable<ITableRowEventBatch<T>> QueryContinuouslyAsync(ContinuousQueryOptions? options = null, CancellationToken cancellationToken = default)

Parameters

options ContinuousQueryOptions

Options.

cancellationToken CancellationToken

Cancellation token.

Returns

IAsyncEnumerable<ITableRowEventBatch<T>>

Infinite IAsyncEnumerable<T> representing an asynchronous stream of batched table events.