* Pipeline events

* Conveyor events

Author: i4004

src/Simplify.Pipelines/Processing/PipelineAction{T}.cs

@@ -0,0 +1,9 @@
+namespace Simplify.Pipelines.Processing
+{
+	/// <summary>
+	/// Provides pipeline related action delegate
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="item">The item.</param>
+	public delegate void PipelineAction<in T>(T item);
+}

src/Simplify.Pipelines/Processing/PipelineStageAction{T}.cs

@@ -0,0 +1,13 @@
+using System;
+
+namespace Simplify.Pipelines.Processing
+{
+	/// <summary>
+	/// Provides pipeline stage action delegate
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="stageType">Type of the stage.</param>
+	/// <param name="item">The item.</param>
+	/// <param name="stageResult">Current pipeline executing stage result.</param>
+	public delegate void PipelineStageAction<in T>(Type stageType, T item, bool stageResult);
+}

src/Simplify.Pipelines/Processing/Pipeline{T}.cs

@@ -1,13 +1,12 @@
 using System.Collections.Generic;
-using System.Linq;
 
 namespace Simplify.Pipelines.Processing
 {
 	/// <summary>
 	/// Provides default pipeline
 	/// </summary>
 	/// <typeparam name="T"></typeparam>
-	/// <seealso cref="Processing.IPipeline{T}" />
+	/// <seealso cref="IPipeline{T}" />
 	public class Pipeline<T> : IPipeline<T>
 	{
 		private readonly IList<IPipelineStage<T>> _stages;
@@ -21,15 +20,43 @@ public Pipeline(IList<IPipelineStage<T>> stages)
 			_stages = stages;
 		}
 
+		/// <summary>
+		/// Occurs when pipeline is about to execute.
+		/// </summary>
+		public event PipelineAction<T> OnPipelineStart;
+
+		/// <summary>
+		/// Occurs when pipeline has finished it's execution.
+		/// </summary>
+		public event PipelineAction<T> OnPipelineEnd;
+
+		/// <summary>
+		/// Occurs when pipeline stage has finished it's execution.
+		/// </summary>
+		public event PipelineStageAction<T> OnStageExecuted;
+
 		/// <summary>
 		/// Process pipeline stages.
 		/// </summary>
 		/// <param name="item">The item for execution.</param>
 		/// <returns></returns>
-
 		public virtual bool Execute(T item)
 		{
-			return _stages.All(stage => stage.Execute(item));
+			OnPipelineStart?.Invoke(item);
+
+			foreach (var stage in _stages)
+			{
+				var result = !stage.Execute(item);
+
+				OnStageExecuted?.Invoke(stage.GetType(), item, result);
+
+				if (result == false)
+					return false;
+			}
+
+			OnPipelineEnd?.Invoke(item);
+
+			return true;
 		}
 	}
 }

src/Simplify.Pipelines/Processing/ResultingPipeline{T}.cs

@@ -7,7 +7,7 @@ namespace Simplify.Pipelines.Processing
 	/// </summary>
 	/// <typeparam name="T"></typeparam>
 	/// <typeparam name="TResult">The type of the result.</typeparam>
-	/// <seealso cref="Simplify.Pipelines.Processing.IResultingPipeline{T, TResult}" />
+	/// <seealso cref="IResultingPipeline{T, TResult}" />
 	public class ResultingPipeline<T, TResult> : IResultingPipeline<T, TResult>
 	{
 		private readonly IList<IResultingPipelineStage<T, TResult>> _stages;

src/Simplify.Pipelines/ProductionLine/ConveyorAction{T}.cs

@@ -0,0 +1,9 @@
+namespace Simplify.Pipelines.ProductionLine
+{
+	/// <summary>
+	/// Provides conveyor related action delegate
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="item">The item.</param>
+	public delegate void ConveyorAction<in T>(T item);
+}

src/Simplify.Pipelines/ProductionLine/ConveyorStageAction{T}.cs

@@ -0,0 +1,12 @@
+using System;
+
+namespace Simplify.Pipelines.ProductionLine
+{
+	/// <summary>
+	/// Provides conveyor stage action delegate
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="stageType">Type of the stage.</param>
+	/// <param name="item">The item.</param>
+	public delegate void ConveyorStageAction<in T>(Type stageType, T item);
+}

src/Simplify.Pipelines/ProductionLine/Conveyor{T}.cs

@@ -22,14 +22,30 @@ public Conveyor(IList<IConveyorStage<T>> stages)
 			_stages = stages ?? throw new ArgumentNullException(nameof(stages));
 		}
 
+		/// <summary>
+		/// Occurs when conveyor is about to execute.
+		/// </summary>
+		public event ConveyorAction<T> OnConveyorStart;
+
+		/// <summary>
+		/// Occurs when conveyor stage has finished it's execution.
+		/// </summary>
+		public event ConveyorStageAction<T> OnStageExecuted;
+
 		/// <summary>
 		/// Executes the specified item thru conveyor.
 		/// </summary>
 		/// <param name="item">The item.</param>
 		public void Execute(T item)
 		{
+			OnConveyorStart?.Invoke(item);
+
 			foreach (var stage in _stages)
+			{
 				stage.Execute(item);
+
+				OnStageExecuted?.Invoke(stage.GetType(), item);
+			}
 		}
 	}
 }

src/Simplify.Pipelines/Simplify.Pipelines.csproj

@@ -5,15 +5,16 @@
 		<Product>Simplify</Product>
 		<Description>Pipelines processing, validation patterns</Description>
 		<Copyright>Licensed under LGPL</Copyright>
-		<Version>0.5.1</Version>
+		<Version>0.6</Version>
 		<PackageProjectUrl>https://github.com/SimplifyNet/Simplify</PackageProjectUrl>
 		<PackageIconUrl>https://raw.githubusercontent.com/SimplifyNet/Images/master/Logo.png</PackageIconUrl>
 		<RepositoryUrl>https://github.com/SimplifyNet/Simplify/tree/master/src/Simplify.Pipelines</RepositoryUrl>
 		<RepositoryType>GIT</RepositoryType>
 		<PackageTags>.NET pipelines</PackageTags>
 		<PackageReleaseNotes>
-			Updates
-			* Names refactored
+			New
+			* Pipeline events
+			* Conveyor events
 		</PackageReleaseNotes>
 		<OutputPath>bin\Any CPU\$(Configuration)\</OutputPath>
 		<DocumentationFile>bin\Any CPU\$(Configuration)\$(TargetFramework)\Simplify.Pipelines.xml</DocumentationFile>