Interface IConsumer<T> (5.0.0)

public interface IConsumer<T> : IDisposable

A consumer.

Namespace

Google.Cloud.Diagnostics.Common

Assembly

Google.Cloud.Diagnostics.Common.dll

Type Parameter

NameDescription
T

Methods

Receive(IEnumerable<T>)

void Receive(IEnumerable<T> items)

Accepts an enumerable of items.

Parameter
NameDescription
itemsIEnumerable<T>

The items to receive. Must not be null.

ReceiveAsync(IEnumerable<T>, CancellationToken)

Task ReceiveAsync(IEnumerable<T> items, CancellationToken cancellationToken = default(CancellationToken))

Accepts an enumerable of items asynchronously.

Parameters
NameDescription
itemsIEnumerable<T>

The items to receive. Must not be null.

cancellationTokenCancellationToken

The token to monitor for cancellation requests.

Returns
TypeDescription
Task

A task representing the asynchronous operation.