Skip to content

Commit 24a543d

Browse files
committed
Merge branch 'develop'
2 parents e448d9f + b0998b6 commit 24a543d

96 files changed

Lines changed: 1707 additions & 1575 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

Build/build.ps1

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
Set-Location ../
2+
dotnet build ./Streamliner.sln --configuration Release
3+
dotnet pack ./Streamliner.sln --configuration Release
4+
5+
Write-Host -NoNewLine 'Press any key to continue...';
6+
$null = $Host.UI.RawUI.ReadKey('NoEcho,IncludeKeyDown');

NuGet-Avatar.png

37.8 KB
Loading

README.md

Lines changed: 16 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,12 @@
11
# Streamliner
2-
A .NET 7 library that enables the creation of code workflows that isolate responsibilities.
2+
A .NET library that enables the creation of code workflows that isolate responsibilities.
33
Streamliner creates a directed acyclic graph which represents the workflow in separate, single responsibility blocks.
44

5-
For the .NET Core 3.1 version, please refer to the [respectful branch](https://github.com/Codeh4ck/Streamliner/tree/dotnet-core-3.1).
6-
For .NET 6, install version 1.3.x from NuGet.
5+
| **.NET Runtime** | **Supported Versions** |
6+
|------------------ |--------------------------------------------- |
7+
| .NET Core | 2.0, 2.1, 2.2, 3.0, 3.1 |
8+
| .NET Framework | 4.6.1, 4.6.2, 4.7, 4.7.1, 4.7.2, 4.8, 4.8.1 |
9+
| .NET | 5, 6, 7 |
710

811
### Check the [examples](https://github.com/Codeh4ck/Streamliner/tree/examples) branch for example projects.
912

@@ -23,6 +26,16 @@ PM> Install-Package Streamliner
2326

2427
Alternatively, you can clone the repository, compile the source code and add ```Streamliner.dll``` to your references.
2528

29+
# Build
30+
31+
Open Streamliner.sln on your Visual Studio. Open a terminal on the root path of the solution (View -> Terminal).
32+
33+
Run the following command:
34+
35+
```
36+
dotnet build --configuration Release
37+
```
38+
2639
# What kind of flows does Streamliner support?
2740

2841
Currently Streamliner supports two kinds of flows:

Streamliner.sln

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,15 @@
11

22
Microsoft Visual Studio Solution File, Format Version 12.00
3-
# Visual Studio Version 16
4-
VisualStudioVersion = 16.0.29318.209
3+
# Visual Studio Version 17
4+
VisualStudioVersion = 17.5.33424.131
55
MinimumVisualStudioVersion = 10.0.40219.1
66
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Streamliner", "Streamliner\Streamliner.csproj", "{A6171024-CA6F-4F17-94A8-C76A39321BDD}"
77
EndProject
88
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{CEB07972-8AEC-4E75-8354-EAE9E7A93BC6}"
99
ProjectSection(SolutionItems) = preProject
1010
.gitignore = .gitignore
1111
LICENSE = LICENSE
12+
NuGet-Avatar.png = NuGet-Avatar.png
1213
README.md = README.md
1314
EndProjectSection
1415
EndProject

Streamliner/Actions/BlockActionBase.cs

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,15 @@
22
using Streamliner.Core.Utilities.Auditing;
33
using Streamliner.Definitions.Metadata.Blocks;
44

5-
namespace Streamliner.Actions;
6-
7-
public abstract class BlockActionBase : Runnable
5+
namespace Streamliner.Actions
86
{
9-
public object Context { get; set; }
10-
public ILogger Logger { get; set; }
11-
public BlockHeader Header { get; set; }
7+
public abstract class BlockActionBase : Runnable
8+
{
9+
public object Context { get; set; }
10+
public ILogger Logger { get; set; }
11+
public BlockHeader Header { get; set; }
1212

13-
protected override void OnStart(object context = null) { }
14-
protected override void OnStop() { }
13+
protected override void OnStart(object context = null) { }
14+
protected override void OnStop() { }
15+
}
1516
}
Lines changed: 13 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,21 +1,22 @@
11
using System;
22
using Streamliner.Core.Utilities;
33

4-
namespace Streamliner.Actions;
5-
6-
public class BlockActionIocFactory : IBlockActionFactory
4+
namespace Streamliner.Actions
75
{
8-
private readonly DependencyRegistrar _registrar;
6+
public class BlockActionIocFactory : IBlockActionFactory
7+
{
8+
private readonly DependencyRegistrar _registrar;
99

10-
public BlockActionIocFactory(DependencyRegistrar registrar) =>
11-
_registrar = registrar ?? throw new ArgumentNullException(nameof(registrar));
10+
public BlockActionIocFactory(DependencyRegistrar registrar) =>
11+
_registrar = registrar ?? throw new ArgumentNullException(nameof(registrar));
1212

13-
public ProducerBlockActionBase<T> CreateProducerAction<T>(Type type) =>
14-
(ProducerBlockActionBase<T>) _registrar.Resolve(type);
13+
public ProducerBlockActionBase<T> CreateProducerAction<T>(Type type) =>
14+
(ProducerBlockActionBase<T>) _registrar.Resolve(type);
1515

16-
public TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type) =>
17-
(TransformerBlockActionBase<TIn, TOut>) _registrar.Resolve(type);
16+
public TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type) =>
17+
(TransformerBlockActionBase<TIn, TOut>) _registrar.Resolve(type);
1818

19-
public ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type) =>
20-
(ConsumerBlockActionBase<TOut>) _registrar.Resolve(type);
19+
public ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type) =>
20+
(ConsumerBlockActionBase<TOut>) _registrar.Resolve(type);
21+
}
2122
}
Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,9 @@
11
using System.Threading;
22

3-
namespace Streamliner.Actions;
4-
5-
public abstract class ConsumerBlockActionBase<TIn> : BlockActionBase
3+
namespace Streamliner.Actions
64
{
7-
public abstract void Consume(TIn model, CancellationToken token = default);
5+
public abstract class ConsumerBlockActionBase<TIn> : BlockActionBase
6+
{
7+
public abstract void Consume(TIn model, CancellationToken token = default);
8+
}
89
}
Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,11 @@
11
using System;
22

3-
namespace Streamliner.Actions;
4-
5-
public interface IBlockActionFactory
3+
namespace Streamliner.Actions
64
{
7-
ProducerBlockActionBase<T> CreateProducerAction<T>(Type type);
8-
TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type);
9-
ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type);
5+
public interface IBlockActionFactory
6+
{
7+
ProducerBlockActionBase<T> CreateProducerAction<T>(Type type);
8+
TransformerBlockActionBase<TIn, TOut> CreateTransformerAction<TIn, TOut>(Type type);
9+
ConsumerBlockActionBase<TOut> CreateConsumerAction<TOut>(Type type);
10+
}
1011
}
Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,9 @@
11
using System.Threading;
22

3-
namespace Streamliner.Actions;
4-
5-
public abstract class ProducerBlockActionBase<T> : BlockActionBase
3+
namespace Streamliner.Actions
64
{
7-
public abstract bool TryProduce(out T model, CancellationToken token = default);
5+
public abstract class ProducerBlockActionBase<T> : BlockActionBase
6+
{
7+
public abstract bool TryProduce(out T model, CancellationToken token = default);
8+
}
89
}
Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,9 @@
11
using System.Threading;
22

3-
namespace Streamliner.Actions;
4-
5-
public abstract class TransformerBlockActionBase<TIn, TOut> : BlockActionBase
3+
namespace Streamliner.Actions
64
{
7-
public abstract bool TryTransform(TIn input, out TOut model, CancellationToken token = default);
5+
public abstract class TransformerBlockActionBase<TIn, TOut> : BlockActionBase
6+
{
7+
public abstract bool TryTransform(TIn input, out TOut model, CancellationToken token = default);
8+
}
89
}

0 commit comments

Comments
 (0)