-
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #12 from FRACerqueira/v1.0.3
V1.0.3
- Loading branch information
Showing
40 changed files
with
1,975 additions
and
533 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,85 @@ | ||
| namespace PipeFilterCore | ||
| { | ||
| /// <summary> | ||
| /// Represents the commands after running Aggregate pipe. | ||
| /// </summary> | ||
| /// <typeparam name="T">Type of contract.</typeparam> | ||
| public interface IPipeAndFilterAfterAggregate<T> : IPipeAndFilterBuild<T> where T : class | ||
| { | ||
| /// <summary> | ||
| /// Add new pipe. | ||
| /// </summary> | ||
| /// <param name="command">The handler to execute.</param> | ||
| /// <param name="alias"> | ||
| /// The unique alias for pipe. | ||
| /// <br>If the alias is omitted, the alias will be the handler name followed by the reference quantity (if any).</br> | ||
| /// <br>Alias is used to reference in another pipe.</br> | ||
| /// </param> | ||
| /// <returns><see cref="IPipeAndFilterPipe{T}"/></returns> | ||
| IPipeAndFilterPipe<T> AddPipe(Func<EventPipe<T>, CancellationToken, Task>?command = null, string? alias = null); | ||
|
|
||
| /// <summary> | ||
| /// Add new aggregate pipe. | ||
| /// </summary> | ||
| /// <param name="command">The handler to execute. | ||
| /// <br>The handler command will run after all tasks are executed.</br> | ||
| /// </param> | ||
| /// <param name="alias"> | ||
| /// The unique alias for pipe. | ||
| /// <br>If the alias is omitted, the alias will be the handler name followed by the reference quantity (if any).</br> | ||
| /// <br>Alias is used to reference in another pipe.</br> | ||
| /// </param> | ||
| /// <returns><see cref="IPipeAndFilterAggregate{T}"/></returns> | ||
| IPipeAndFilterAggregate<T> AddAggregatePipe(Func<EventPipe<T>, CancellationToken, Task>? command = null, string? alias = null); | ||
|
|
||
| /// <summary> | ||
| /// Add new task (execution in parallel) through pipe. | ||
| /// </summary> | ||
| /// <param name="command">The handler to execute.</param> | ||
| /// <param name="nametask">The name for task (optional).</param> | ||
| /// <returns><see cref="IPipeAndFilterAfterAggregate{T}"/></returns> | ||
| IPipeAndFilterAfterAggregate<T> AddTask(Func<EventPipe<T>, CancellationToken, Task> command, string? nametask = null); | ||
|
|
||
| /// <summary> | ||
| /// Maximum number of concurrent tasks enable. | ||
| /// </summary> | ||
| /// <param name="value"> | ||
| /// Number of concurrent tasks. | ||
| /// <br>The default value is number of processors.</br> | ||
| /// </param> | ||
| /// <returns><see cref="IPipeAndFilterAfterAggregate{T}"/></returns> | ||
| IPipeAndFilterAfterAggregate<T> MaxDegreeProcess(int value); | ||
|
|
||
|
|
||
| /// <summary> | ||
| /// Add new task (execution in parallel) through pipe with conditions. | ||
| /// </summary> | ||
| /// <param name="command">The handler to execute.</param> | ||
| /// <param name="nametask">The name for task (optional).</param> | ||
| /// <returns><see cref="IPipeAndFilterAfterAggregateCondition{T}"/></returns> | ||
| IPipeAndFilterAfterAggregateCondition<T> AddTaskCondition(Func<EventPipe<T>, CancellationToken, Task> command, string? nametask = null); | ||
|
|
||
| /// <summary> | ||
| /// Add new condition. | ||
| /// </summary> | ||
| /// <param name="condition">The handle to execute.</param> | ||
| /// <param name="namecondition">The name for condition(optional).</param> | ||
| /// <returns><see cref="IPipeAndFilterAfterAggregate{T}"/></returns> | ||
| IPipeAndFilterAfterAggregate<T> WithCondition(Func<EventPipe<T>, CancellationToken, ValueTask<bool>> condition, string? namecondition = null); | ||
|
|
||
| /// <summary> | ||
| /// Add new go to condition. | ||
| /// <br>If the condition is true, jump to the given pipe without executing the current pipe.</br> | ||
| /// <br>If the false condition continues.</br> | ||
| /// </summary> | ||
| /// <param name="condition">The handle to execute.</param> | ||
| /// <param name="aliasgoto"> | ||
| /// The alias to another pipe. | ||
| /// </param> | ||
| /// <param name="namecondition">The name for condition(optional).</param> | ||
| /// <returns><see cref="IPipeAndFilterAfterAggregate{T}"/></returns> | ||
| IPipeAndFilterAfterAggregate<T> WithGotoCondition(Func<EventPipe<T>, CancellationToken, ValueTask<bool>> condition, string aliasgoto, string? namecondition = null); | ||
|
|
||
|
|
||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.