Merge branch 'develop'

Author: Codeh4ck

README.md

@@ -1,8 +1,9 @@
 # Streamliner
-A .NET 6 library that enables the creation of code workflows that isolate responsibilities. 
+A .NET 7 library that enables the creation of code workflows that isolate responsibilities. 
 Streamliner creates a directed acyclic graph which represents the workflow in separate, single responsibility blocks.
 
 For the .NET Core 3.1 version, please refer to the [respectful branch](https://github.com/Codeh4ck/Streamliner/tree/dotnet-core-3.1).
+For .NET 6, install version 1.3.x from NuGet.
 
 ### Check the [examples](https://github.com/Codeh4ck/Streamliner/tree/examples) branch for example projects.
 

Streamliner/Actions/BlockActionBase.cs

@@ -2,15 +2,14 @@
 using Streamliner.Core.Utilities.Auditing;
 using Streamliner.Definitions.Metadata.Blocks;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public abstract class BlockActionBase : Runnable
 {
-    public abstract class BlockActionBase : Runnable
-    {
-        public object Context { get; set; }
-        public ILogger Logger { get; set; }
-        public BlockHeader Header { get; set; }
+    public object Context { get; set; }
+    public ILogger Logger { get; set; }
+    public BlockHeader Header { get; set; }
 
-        protected override void OnStart(object context = null) { }
-        protected override void OnStop() { }
-    }
-}
+    protected override void OnStart(object context = null) { }
+    protected override void OnStop() { }
+}

Streamliner/Actions/BlockActionIocFactory.cs

@@ -1,31 +1,21 @@
 using System;
 using Streamliner.Core.Utilities;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public class BlockActionIocFactory : IBlockActionFactory
 {
-    public class BlockActionIocFactory : IBlockActionFactory
-    {
-        private readonly DependencyRegistrar _registrar;
+    private readonly DependencyRegistrar _registrar;
 
-        public BlockActionIocFactory(DependencyRegistrar registrar)
-        {
-            if (registrar == null) throw new ArgumentNullException(nameof(registrar));
-            _registrar = registrar;
-        }
+    public BlockActionIocFactory(DependencyRegistrar registrar) => 
+        _registrar = registrar ?? throw new ArgumentNullException(nameof(registrar));
 
-        public ProducerBlockActionBase<T> CreateProducerAction<T>(Type type)
-        {
-            return (ProducerBlockActionBase<T>) _registrar.Resolve(type);
-        }
+    public ProducerBlockActionBase<T> CreateProducerAction<T>(Type type) => 
+        (ProducerBlockActionBase<T>) _registrar.Resolve(type);
 
-        public TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type)
-        {
-            return (TransformerBlockActionBase<TIn, TOut>) _registrar.Resolve(type);
-        }
+    public TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type) => 
+        (TransformerBlockActionBase<TIn, TOut>) _registrar.Resolve(type);
 
-        public ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type)
-        {
-            return (ConsumerBlockActionBase<TOut>) _registrar.Resolve(type);
-        }
-    }
-}
+    public ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type) => 
+        (ConsumerBlockActionBase<TOut>) _registrar.Resolve(type);
+}

Streamliner/Actions/ConsumerBlockActionBase.cs

@@ -1,9 +1,8 @@
 using System.Threading;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public abstract class ConsumerBlockActionBase<TIn> : BlockActionBase
 {
-    public abstract class ConsumerBlockActionBase<TIn> : BlockActionBase
-    {
-        public abstract void Consume(TIn model, CancellationToken token = default(CancellationToken));
-    }
-}
+    public abstract void Consume(TIn model, CancellationToken token = default);
+}

Streamliner/Actions/IBlockActionFactory.cs

@@ -1,11 +1,10 @@
 using System;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public interface IBlockActionFactory
 {
-    public interface IBlockActionFactory
-    {
-        ProducerBlockActionBase<T> CreateProducerAction<T>(Type type);
-        TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type);
-        ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type);
-    }
-}
+    ProducerBlockActionBase<T> CreateProducerAction<T>(Type type);
+    TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type);
+    ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type);
+}

Streamliner/Actions/ProducerBlockActionBase.cs

@@ -1,9 +1,8 @@
 using System.Threading;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public abstract class ProducerBlockActionBase<T> : BlockActionBase
 {
-    public abstract class ProducerBlockActionBase<T> : BlockActionBase
-    {
-        public abstract bool TryProduce(out T model, CancellationToken token = default(CancellationToken));
-    }
-}
+    public abstract bool TryProduce(out T model, CancellationToken token = default);
+}

Streamliner/Actions/TransformerBlockActionBase.cs

@@ -1,9 +1,8 @@
 using System.Threading;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public abstract class TransformerBlockActionBase<TIn, TOut> : BlockActionBase
 {
-    public abstract class TransformerBlockActionBase<TIn, TOut> : BlockActionBase
-    {
-        public abstract bool TryTransform(TIn input, out TOut model, CancellationToken token = default(CancellationToken));
-    }
-}
+    public abstract bool TryTransform(TIn input, out TOut model, CancellationToken token = default);
+}

Streamliner/Actions/TriggerContext.cs

@@ -1,10 +1,9 @@
 using System;
 
-namespace Streamliner.Actions
+namespace Streamliner.Actions;
+
+public class TriggerContext<T>
 {
-    public class TriggerContext<T>
-    {
-        public Guid? Id { get; set; }
-        public T Item { get; set; }
-    }
-}
+    public Guid? Id { get; set; }
+    public T Item { get; set; }
+}