PipeAndFilter API:IPipeAndFilterStart
IPipeAndFilterStart<T>
Namespace: PipeFilterCore
Represents the commands for Pipes.
public interface IPipeAndFilterStart<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.