Interface IClientStreamCommandHandler<T, TResult>
interface to be implemented by a command handler for a stream of T that returns a single TResult.
Namespace: FastEndpoints
Assembly: FastEndpoints.Messaging.Core.dll
Syntax
public interface IClientStreamCommandHandler<T, TResult> where T : class where TResult : classType Parameters
| Name | Description |
|---|---|
| T | the type of item in the stream |
| TResult | the type of the result returned when the stream ends |
Methods
ExecuteAsync(IAsyncEnumerable<T>, CancellationToken)
accepts a stream of T and returns a TResult when the stream ends.
Declaration
Task<TResult> ExecuteAsync(IAsyncEnumerable<T> stream, CancellationToken ct)Parameters
| Type | Name | Description |
|---|---|---|
| IAsyncEnumerable<T> | stream | the stream of incoming items |
| CancellationToken | ct | optional cancellation token |
Returns
| Type | Description |
|---|---|
| Task<TResult> |