Interface IConsumer<T>
A consumer.
Inherited Members
System.IDisposable.Dispose()
Namespace: Google.Cloud.Diagnostics.Common
Assembly: Google.Cloud.Diagnostics.Common.dll
Syntax
public interface IConsumer<T> : IDisposableType Parameters
| Name | Description |
|---|---|
| T |
Methods
Receive(IEnumerable<T>)
Accepts an enumerable of items.
Declaration
void Receive(IEnumerable<T> items)Parameters
| Type | Name | Description |
|---|---|---|
| System.Collections.Generic.IEnumerable<T> | items | The items to receive. Must not be null. |
ReceiveAsync(IEnumerable<T>, CancellationToken)
Accepts an enumerable of items asynchronously.
Declaration
Task ReceiveAsync(IEnumerable<T> items, CancellationToken cancellationToken = default(CancellationToken))Parameters
| Type | Name | Description |
|---|---|---|
| System.Collections.Generic.IEnumerable<T> | items | The items to receive. Must not be null. |
| System.Threading.CancellationToken | cancellationToken | The token to monitor for cancellation requests. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | A task representing the asynchronous operation. |