diff --git a/Examples/Example1/CompnentBased/Stage2.cs b/Examples/Example1/CompnentBased/Stage2.cs deleted file mode 100644 index 42339e1..0000000 --- a/Examples/Example1/CompnentBased/Stage2.cs +++ /dev/null @@ -1,31 +0,0 @@ -using System; -using Fibrous; -using Fibrous.Pipelines; - -namespace Example1.CompnentBased -{ - public class Stage2 : IProcessor - { - private readonly ISomeDataAccess _dal; - - public Stage2(ISomeDataAccess service) - { - _dal = service; - } - - public event Action Output; - public event Action Exception; - - public void Process(Payload input) - { - //Do some other things and save to a database - _dal.SaveData(input); - Output?.Invoke(input); - } - - public void Initialize(IScheduler scheduler) - { - //If we don't need scheduling for this stage, leave empty - } - } -} diff --git a/Examples/Example1/CompnentBased/Channels.cs b/Examples/Example1/ComponentBased/Channels.cs similarity index 93% rename from Examples/Example1/CompnentBased/Channels.cs rename to Examples/Example1/ComponentBased/Channels.cs index a6e8279..26f3064 100644 --- a/Examples/Example1/CompnentBased/Channels.cs +++ b/Examples/Example1/ComponentBased/Channels.cs @@ -1,7 +1,7 @@ using System; using Fibrous; -namespace Example1.CompnentBased +namespace Example1.ComponentBased { public class Channels { diff --git a/Examples/Example1/CompnentBased/ISomeDataAccess.cs b/Examples/Example1/ComponentBased/ISomeDataAccess.cs similarity index 89% rename from Examples/Example1/CompnentBased/ISomeDataAccess.cs rename to Examples/Example1/ComponentBased/ISomeDataAccess.cs index 90cd468..27886fb 100644 --- a/Examples/Example1/CompnentBased/ISomeDataAccess.cs +++ b/Examples/Example1/ComponentBased/ISomeDataAccess.cs @@ -1,6 +1,6 @@ using System; -namespace Example1.CompnentBased +namespace Example1.ComponentBased { public interface ISomeDataAccess { diff --git a/Examples/Example1/CompnentBased/ISomeService.cs b/Examples/Example1/ComponentBased/ISomeService.cs similarity index 89% rename from Examples/Example1/CompnentBased/ISomeService.cs rename to Examples/Example1/ComponentBased/ISomeService.cs index f6eabf2..086c26f 100644 --- a/Examples/Example1/CompnentBased/ISomeService.cs +++ b/Examples/Example1/ComponentBased/ISomeService.cs @@ -1,6 +1,6 @@ using System; -namespace Example1.CompnentBased +namespace Example1.ComponentBased { public interface ISomeService { diff --git a/Examples/Example1/CompnentBased/Payload.cs b/Examples/Example1/ComponentBased/Payload.cs similarity index 83% rename from Examples/Example1/CompnentBased/Payload.cs rename to Examples/Example1/ComponentBased/Payload.cs index 7240414..8e3a6a0 100644 --- a/Examples/Example1/CompnentBased/Payload.cs +++ b/Examples/Example1/ComponentBased/Payload.cs @@ -1,6 +1,6 @@ using System.Collections.Generic; -namespace Example1.CompnentBased +namespace Example1.ComponentBased { public class Payload { diff --git a/Examples/Example1/CompnentBased/Stage1.cs b/Examples/Example1/ComponentBased/Stage1.cs similarity index 97% rename from Examples/Example1/CompnentBased/Stage1.cs rename to Examples/Example1/ComponentBased/Stage1.cs index 5e32c28..2dab39d 100644 --- a/Examples/Example1/CompnentBased/Stage1.cs +++ b/Examples/Example1/ComponentBased/Stage1.cs @@ -2,7 +2,7 @@ using Fibrous; using Fibrous.Pipelines; -namespace Example1.CompnentBased +namespace Example1.ComponentBased { public class Stage1 : IProcessor { diff --git a/Examples/Example1/ComponentBased/Stage2.cs b/Examples/Example1/ComponentBased/Stage2.cs new file mode 100644 index 0000000..f5c1a09 --- /dev/null +++ b/Examples/Example1/ComponentBased/Stage2.cs @@ -0,0 +1,30 @@ +using System; +using Fibrous; +using Fibrous.Pipelines; + +namespace Example1.ComponentBased; + +public class Stage2 : IProcessor +{ + private readonly ISomeDataAccess _dal; + + public Stage2(ISomeDataAccess service) + { + _dal = service; + } + + public event Action Output; + public event Action Exception; + + public void Process(Payload input) + { + //Do some other things and save to a database + _dal.SaveData(input); + Output?.Invoke(input); + } + + public void Initialize(IScheduler scheduler) + { + //If we don't need scheduling for this stage, leave empty + } +} diff --git a/Examples/Example1/PipelineExample.cs b/Examples/Example1/PipelineExample.cs index 2557c77..b4acdde 100644 --- a/Examples/Example1/PipelineExample.cs +++ b/Examples/Example1/PipelineExample.cs @@ -1,6 +1,6 @@ using System; using System.IO; -using Example1.CompnentBased; +using Example1.ComponentBased; using Fibrous; using Fibrous.Pipelines;