PipeAndFilter API:IPipeAndFilterAggregateCondition
IPipeAndFilterAggregateCondition<T>
Namespace: PipeFilterCore
Represents commands conditions for Aggregate pipe.
public interface IPipeAndFilterAggregateCondition<T> : IPipeAndFilterBuild<T>
Type Parameters
T
Type of contract.
Implements IPipeAndFilterBuild<T>
Methods
AddAggregatePipe(Func<EventPipe<T>, CancellationToken, Task>, String)
Add new aggregate pipe.
IPipeAndFilterAggregate<T> AddAggregatePipe(Func<EventPipe<T>, CancellationToken, Task> command, string alias)
Parameters
command Func<EventPipe<T>, CancellationToken, Task>
The handler to execute.
The handler command will run after all tasks are executed.
alias String
The unique alias for pipe.
If the alias is omitted, the alias will be the handler name followed by the reference quantity (if any).
Alias is used to reference in another pipe.
Returns
AddPipe(Func<EventPipe<T>, CancellationToken, Task>, String)
Add new pipe.
IPipeAndFilterPipe<T> AddPipe(Func<EventPipe<T>, CancellationToken, Task> command, string alias)
Parameters
command Func<EventPipe<T>, CancellationToken, Task>
The handler to execute.
alias String
The unique alias for pipe.
If the alias is omitted, the alias will be the handler name followed by the reference quantity (if any).
Alias is used to reference in another pipe.
Returns
AddTask(Func<EventPipe<T>, CancellationToken, Task>, String)
Add new task (execution in parallel) through pipe.
IPipeAndFilterAggregateCondition<T> AddTask(Func<EventPipe<T>, CancellationToken, Task> command, string nametask)
Parameters
command Func<EventPipe<T>, CancellationToken, Task>
The handler to execute.
nametask String
The name for task (optional).
Returns
IPipeAndFilterAggregateCondition<T>
AfterRunning(Func<EventPipe<T>, CancellationToken, Task>, String)
Add new pipe to run after pipe or aggregate pipe completes
IPipeAndFilterAfterPipe<T> AfterRunning(Func<EventPipe<T>, CancellationToken, Task> command, string alias)
Parameters
command Func<EventPipe<T>, CancellationToken, Task>
The handler to execute.
The handler command will run after all tasks are executed.
alias String
The unique alias for pipe.
If the alias is omitted, the alias will be the handler name followed by the reference quantity (if any).
Alias is used to reference in another pipe.
Returns
AfterRunningAggregatePipe(Func<EventPipe<T>, CancellationToken, Task>, String)
Add new pipe aggregate pipe to run after pipe or aggregate pipe completes.
IPipeAndFilterAfterAggregate<T> AfterRunningAggregatePipe(Func<EventPipe<T>, CancellationToken, Task> command, string alias)
Parameters
command Func<EventPipe<T>, CancellationToken, Task>
The handler to execute.
The handler command will run after all tasks are executed.
alias String
The unique alias for pipe.
If the alias is omitted, the alias will be the handler name followed by the reference quantity (if any).
Alias is used to reference in another pipe.
Returns
IPipeAndFilterAfterAggregate<T>
WithCondition(Func<EventPipe<T>, CancellationToken, ValueTask<Boolean>>, String)
Add new condition for task.
IPipeAndFilterAggregateCondition<T> WithCondition(Func<EventPipe<T>, CancellationToken, ValueTask<Boolean>> condition, string namecondition)
Parameters
condition Func<EventPipe<T>, CancellationToken, ValueTask<Boolean>>
The handle to execute.
namecondition String
The name for condition(optional).
Returns
IPipeAndFilterAggregateCondition<T>