Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Master #88

Open
wants to merge 73 commits into
base: master
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
73 commits
Select commit Hold shift + click to select a range
44d82dc
:sparkles: initial commit.
Dec 8, 2017
892040e
IoC support. (#1)
Dec 13, 2017
ad82d19
common work (#2)
Dec 14, 2017
a3d8c7e
pool factory (#3)
Dec 14, 2017
302c2d2
stratum work (#4)
Dec 14, 2017
82766fc
initial jsonrpc & stratum & sockets work. (#5)
Jan 5, 2018
c50bf27
:wrench: added console banner.
Jan 5, 2018
ff60da2
Update README.md
Jan 5, 2018
3061935
Update README.md
Jan 5, 2018
5304534
Update README.md
Jan 5, 2018
a9202a5
Update README.md
Jan 5, 2018
844dfac
Update README.md
Jan 5, 2018
571fc58
Update README.md
Jan 5, 2018
794ff0a
Update README.md
Jan 5, 2018
546833d
Update README.md
Jan 5, 2018
b377397
Update README.md
Jan 5, 2018
a05c63e
Update README.md
Jan 5, 2018
44981ae
initial stratum & hashing work.
Jan 12, 2018
bbf23bd
:wrench: native deps are now copied after build.
Jan 12, 2018
e8dac17
:wrench: added formatted json output support.
Jan 13, 2018
8984000
:wrench: tiny update.
Jan 23, 2018
4418321
Update README.md
Jan 23, 2018
3a8cf42
Update README.md
Jan 23, 2018
c57b25e
Update README.md
Jan 23, 2018
5b27a63
Update README.md
Jan 23, 2018
742b1d8
initial wallet rpc connection done & cooked test project - circle.ci …
Jan 23, 2018
1af4170
:wrench: PooledLineBuffer tests.
Jan 23, 2018
3e35aa3
Update README.md
Jan 24, 2018
15e6c79
Update PooledLineBuffer.cs
Jan 24, 2018
881a749
Update PooledLineBufferTests.cs
Jan 24, 2018
576808a
:books: added license to source files.
Jan 24, 2018
cd0567b
daemon rpc & pool init works (#22)
Jan 24, 2018
c43265b
:wrench: implemented unhandled exception emiter.
Jan 24, 2018
7fb9135
Create CODE_OF_CONDUCT.md
Jan 25, 2018
c28346f
Create CONTRIBUTING.md
Jan 25, 2018
f8d34b9
Create ISSUE_TEMPLATE.md
Jan 25, 2018
f2fd1f0
Create PULL_REQUEST_TEMPLATE.md
Jan 25, 2018
df7d49b
Update README.md
Jan 25, 2018
67135e7
Update README.md
Jan 25, 2018
2e7e094
Update README.md
Jan 25, 2018
644ec77
Update README.md
Jan 25, 2018
0ef4aa8
Update README.md
Jan 25, 2018
37b5d48
Update README.md
Jan 25, 2018
1c8dc77
Update README.md
Jan 25, 2018
a01b142
:wrench: bootstrapper fix.
Jan 25, 2018
7dc2c82
readme updates (#27)
Jan 25, 2018
b7e10b8
Update README.md
Jan 25, 2018
a15d96e
Create appveyor.yml
Jan 25, 2018
b3fadd4
Create issue_template.md
Jan 25, 2018
1e8bb87
:books: moved pull_request_template.md
Jan 25, 2018
0e35b8f
replace IoC with stashbox (#28)
Jan 25, 2018
daff3a6
tiny fix.
Jan 25, 2018
0cedd83
:sparkles: jobmanager work. (#32)
Feb 1, 2018
0befb42
Feature/fast clock (#34)
Feb 1, 2018
78d0310
:bug: tiny benchmark fix for fast-clock.
Feb 1, 2018
2e32ba9
Update README.md
Feb 1, 2018
0828157
more job work.
Feb 2, 2018
9f826e2
more work
Feb 2, 2018
1579933
even more work.
Feb 2, 2018
bc6cbe6
enable appveyor benchmarks.
Feb 2, 2018
a1ab7e5
fix
Feb 2, 2018
8309725
:arrow_up: updated packages.
Feb 19, 2018
023433a
Add renovate.json
renovate-bot Aug 8, 2018
318bc18
Merge pull request #53 from bonesoul/renovate/configure
Aug 8, 2018
b3f2767
Pin dependency grunt-cli to 1.2.0
renovate-bot Aug 8, 2018
a076654
Merge pull request #54 from bonesoul/renovate/pin-dependencies
Aug 8, 2018
0412018
Update dependency BenchmarkDotNet to v0.11.1
renovate-bot Aug 22, 2018
158acb4
Merge pull request #41 from bonesoul/feature/monero-job-work
Aug 27, 2018
1b2d80f
Merge pull request #55 from bonesoul/renovate/benchmarkdotnet-0.x
Aug 27, 2018
24834f9
Update README.md
bitcoinbrisbane Jan 5, 2020
5ff23e7
Merge branch 'develop'
bitcoinbrisbane Jan 5, 2020
b086f08
Fix for build
bitcoinbrisbane Jan 5, 2020
2909960
Updates
bitcoinbrisbane Jan 9, 2020
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
⬆️ updated packages.
huseyin uslu committed Feb 19, 2018
commit 8309725a94a76408aa780ad01bdf7fc2249c9297
2 changes: 1 addition & 1 deletion src/Core/Hypepool.Common/Hypepool.Common.csproj
Original file line number Diff line number Diff line change
@@ -29,7 +29,7 @@

<ItemGroup>
<PackageReference Include="NetUV.Core" Version="0.1.140" />
<PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
<PackageReference Include="Newtonsoft.Json" Version="11.0.1" />
<PackageReference Include="Serilog" Version="2.6.0" />
<PackageReference Include="System.Reactive" Version="3.1.1" />
<PackageReference Include="xunit.analyzers" Version="0.8.0" />
2 changes: 1 addition & 1 deletion src/Core/Hypepool.Core/Hypepool.Core.csproj
Original file line number Diff line number Diff line change
@@ -33,7 +33,7 @@
<PackageReference Include="Serilog" Version="2.6.0" />
<PackageReference Include="Serilog.Enrichers.Thread" Version="3.0.0" />
<PackageReference Include="Serilog.Sinks.ColoredConsole" Version="3.0.1" />
<PackageReference Include="Stashbox" Version="2.5.7" />
<PackageReference Include="Stashbox" Version="2.5.8" />
<PackageReference Include="System.Reactive" Version="3.1.1" />
<PackageReference Include="xunit.analyzers" Version="0.8.0" />
</ItemGroup>
Original file line number Diff line number Diff line change
@@ -26,7 +26,6 @@
using Hypepool.Core.Core;
using Hypepool.Core.Utils.Logging;
using Stashbox;
using Stashbox.Infrastructure;

namespace Hypepool.Core.Internals.Factories.Core
{
Original file line number Diff line number Diff line change
@@ -27,7 +27,6 @@
using System.Linq;
using Hypepool.Common.Pools;
using Stashbox;
using Stashbox.Infrastructure;

namespace Hypepool.Core.Internals.Factories.Pool
{
Original file line number Diff line number Diff line change
@@ -26,7 +26,6 @@
using Hypepool.Common.Factories.Server;
using Hypepool.Common.Stratum;
using Stashbox;
using Stashbox.Infrastructure;

namespace Hypepool.Core.Internals.Factories.Server
{
1 change: 1 addition & 0 deletions src/Tests/Hypepool.Benchmarks/.gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
BenchmarkDotNet.Artifacts/
Original file line number Diff line number Diff line change
@@ -29,7 +29,7 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="FluentAssertions" Version="4.19.4" />
<PackageReference Include="FluentAssertions" Version="5.1.2" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="15.5.0" />
<PackageReference Include="xunit" Version="2.3.1" />
<PackageReference Include="xunit.analyzers" Version="0.8.0" />
10 changes: 5 additions & 5 deletions src/Tests/Hypepool.Common.Tests/Mining/Jobs/JobCounterTests.cs
Original file line number Diff line number Diff line change
@@ -45,8 +45,8 @@ public JobCounterTests()
[Fact]
public void ShouldBeIncremented()
{
_jobCounter.GetNext().ShouldBeEquivalentTo(1);
_jobCounter.GetNext().ShouldBeEquivalentTo(2);
_jobCounter.GetNext().Should().Be(1);
_jobCounter.GetNext().Should().Be(2);
}

[Fact]
@@ -58,13 +58,13 @@ public void ShouldResetBackAfterMaxValue()

// set it to int.MaxValue - 1
last.SetValue(_jobCounter, int.MaxValue - 1);
last.GetValue(_jobCounter).ShouldBeEquivalentTo(int.MaxValue - 1);
last.GetValue(_jobCounter).Should().Be(int.MaxValue - 1);

// GetNext() and should be int.MaxValue now.
_jobCounter.GetNext().ShouldBeEquivalentTo(int.MaxValue);
_jobCounter.GetNext().Should().Be(int.MaxValue);

// another GetNext() and should reset back to 1 now.
_jobCounter.GetNext().ShouldBeEquivalentTo(1);
_jobCounter.GetNext().Should().Be(1);
}
}
}
Original file line number Diff line number Diff line change
@@ -37,7 +37,7 @@ public class ContainerTests
public void VerifyContainer()
{
Action act = () => new Bootstrapper(); // verify the container.
act.ShouldNotThrow();
act.Should().NotThrow();
}
}
}
2 changes: 1 addition & 1 deletion src/Tests/Hypepool.Core.Tests/Hypepool.Core.Tests.csproj
Original file line number Diff line number Diff line change
@@ -29,7 +29,7 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="FluentAssertions" Version="4.19.4" />
<PackageReference Include="FluentAssertions" Version="5.1.2" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="15.5.0" />
<PackageReference Include="xunit" Version="2.3.1" />
<PackageReference Include="xunit.analyzers" Version="0.8.0" />
Original file line number Diff line number Diff line change
@@ -49,8 +49,8 @@ public void PooledLineBuffer_Partial_Line()
(src, dst, count) => Array.Copy(src, 0, dst, 0, count),
(x) => recvCount++, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(0);
errCount.ShouldBeEquivalentTo(0);
recvCount.Should().Be(0);
errCount.Should().Be(0);
}

[Fact]
@@ -72,8 +72,8 @@ public void PooledLineBuffer_Partial_Line_Double()
(src, dst, count) => Array.Copy(src, 0, dst, 0, count),
(x) => recvCount++, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(0);
errCount.ShouldBeEquivalentTo(0);
recvCount.Should().Be(0);
errCount.Should().Be(0);
}

[Fact]
@@ -100,9 +100,9 @@ public void PooledLineBuffer_Partial_Line_Double_With_NewLine()
result = GetString(x);
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(1);
errCount.ShouldBeEquivalentTo(0);
result.ShouldBeEquivalentTo("deadbeef");
recvCount.Should().Be(1);
errCount.Should().Be(0);
result.Should().Be("deadbeef");
}

[Fact]
@@ -129,9 +129,9 @@ public void PooledLineBuffer_Partial_Line_Double_With_NewLine_With_Leading_NewLi
result = GetString(x);
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(1);
errCount.ShouldBeEquivalentTo(0);
result.ShouldBeEquivalentTo("deadbeef");
recvCount.Should().Be(1);
errCount.Should().Be(0);
result.Should().Be("deadbeef");
}

[Fact]
@@ -158,9 +158,9 @@ public void PooledLineBuffer_Partial_Line_Double_With_NewLine_With_Trailing_NewL
result = GetString(x);
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(1);
errCount.ShouldBeEquivalentTo(0);
result.ShouldBeEquivalentTo("deadbeef");
recvCount.Should().Be(1);
errCount.Should().Be(0);
result.Should().Be("deadbeef");
}

[Fact]
@@ -179,8 +179,8 @@ public void PooledLineBuffer_Partial_Dont_Emit_Empty_Lines()
recvCount++;
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(0);
errCount.ShouldBeEquivalentTo(0);
recvCount.Should().Be(0);
errCount.Should().Be(0);
}

[Fact]
@@ -199,8 +199,8 @@ public void PooledLineBuffer_Partial_Enforce_Limits()
recvCount++;
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(0);
errCount.ShouldBeEquivalentTo(1);
recvCount.Should().Be(0);
errCount.Should().Be(1);
}

[Fact]
@@ -219,8 +219,8 @@ public void PooledLineBuffer_Partial_Enforce_Limits_Queued()
recvCount++;
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(0);
errCount.ShouldBeEquivalentTo(0);
recvCount.Should().Be(0);
errCount.Should().Be(0);

buf = GetBuffer("bee");

@@ -231,8 +231,8 @@ public void PooledLineBuffer_Partial_Enforce_Limits_Queued()
recvCount++;
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(0);
errCount.ShouldBeEquivalentTo(1);
recvCount.Should().Be(0);
errCount.Should().Be(1);
}

[Fact]
@@ -253,9 +253,9 @@ public void PooledLineBuffer_Single_Line()
result = GetString(x);
}, (ex) => errCount++);

recvCount.ShouldBeEquivalentTo(1);
errCount.ShouldBeEquivalentTo(0);
result.ShouldBeEquivalentTo("dead");
recvCount.Should().Be(1);
errCount.Should().Be(0);
result.Should().Be("dead");
}

[Fact]
@@ -274,12 +274,12 @@ public void PooledLineBuffer_Multi_Line_Batch()
results.Add(GetString(x));
}, (ex) => errCount++);

results.Count.ShouldBeEquivalentTo(3);
errCount.ShouldBeEquivalentTo(0);
results.Count.Should().Be(3);
errCount.Should().Be(0);

results[0].ShouldBeEquivalentTo("dead");
results[1].ShouldBeEquivalentTo("beef");
results[2].ShouldBeEquivalentTo("c0de");
results[0].Should().Be("dead");
results[1].Should().Be("beef");
results[2].Should().Be("c0de");
}

[Fact]
@@ -316,9 +316,9 @@ public void PooledLineBuffer_Single_Characters()
results.Add(GetString(x));
}, (ex) => errCount++);

results.Count.ShouldBeEquivalentTo(1);
errCount.ShouldBeEquivalentTo(0);
results[0].ShouldBeEquivalentTo("abc");
results.Count.Should().Be(1);
errCount.Should().Be(0);
results[0].Should().Be("abc");
}

[Fact]
@@ -355,11 +355,11 @@ public void PooledLineBuffer_Single_Character_Lines()
results.Add(GetString(x));
}, (ex) => errCount++);

results.Count.ShouldBeEquivalentTo(3);
errCount.ShouldBeEquivalentTo(0);
results[0].ShouldBeEquivalentTo("a");
results[1].ShouldBeEquivalentTo("b");
results[2].ShouldBeEquivalentTo("c");
results.Count.Should().Be(3);
errCount.Should().Be(0);
results[0].Should().Be("a");
results[1].Should().Be("b");
results[2].Should().Be("c");
}

[Fact]
@@ -378,9 +378,9 @@ public void PooledLineBuffer_Combo1()
results.Add(GetString(x));
}, (ex) => errCount++);

results.Count.ShouldBeEquivalentTo(1);
errCount.ShouldBeEquivalentTo(0);
results[0].ShouldBeEquivalentTo("dead");
results.Count.Should().Be(1);
errCount.Should().Be(0);
results[0].Should().Be("dead");
}

[Fact]
@@ -408,10 +408,10 @@ public void PooledLineBuffer_Combo2()
results.Add(GetString(x));
}, (ex) => errCount++);

results.Count.ShouldBeEquivalentTo(2);
errCount.ShouldBeEquivalentTo(0);
results[0].ShouldBeEquivalentTo("dead");
results[1].ShouldBeEquivalentTo("beefc0de");
results.Count.Should().Be(2);
errCount.Should().Be(0);
results[0].Should().Be("dead");
results[1].Should().Be("beefc0de");
}

[Fact]
@@ -448,11 +448,11 @@ public void PooledLineBuffer_Combo3()
results.Add(GetString(x));
}, (ex) => errCount++);

results.Count.ShouldBeEquivalentTo(3);
errCount.ShouldBeEquivalentTo(0);
results[0].ShouldBeEquivalentTo("dead");
results[1].ShouldBeEquivalentTo("beefc0defeed");
results[2].ShouldBeEquivalentTo("babe");
results.Count.Should().Be(3);
errCount.Should().Be(0);
results[0].Should().Be("dead");
results[1].Should().Be("beefc0defeed");
results[2].Should().Be("babe");
}

private byte[] GetBuffer(string str)
Original file line number Diff line number Diff line change
@@ -29,7 +29,7 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="FluentAssertions" Version="4.19.4" />
<PackageReference Include="FluentAssertions" Version="5.1.2" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="15.5.0" />
<PackageReference Include="Microsoft.Reactive.Testing" Version="3.1.1" />
<PackageReference Include="NSubstitute" Version="3.1.0" />
38 changes: 19 additions & 19 deletions src/Tests/Hypepool.Monero.Tests/JobManager/JobManagerTests.cs
Original file line number Diff line number Diff line change
@@ -79,23 +79,23 @@ public async void ShouldGetANewJobOnDifferentBlocktemplates()
// check first job.
await _jobManager.JobQueue.Take(1).Do(job =>
{
job.BlockTemplate.Blob.ShouldBeEquivalentTo("07079ccdc1d3053b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b0000000002e3b64201ffa7b64201b3be90f18de9010258f3cdf062d631c578597ad4aa00bb6e99bbbdc816fa295286ea956c2d15e1cf2b0109d8ec8c47fb41668d69ef2ce3764a906285bbab66a127247f627b939380ddc7020800000000000000000000");
job.BlockTemplate.Difficulty.ShouldBeEquivalentTo(23096);
job.BlockTemplate.Height.ShouldBeEquivalentTo(1088295);
job.BlockTemplate.PreviousBlockhash.ShouldBeEquivalentTo("3b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b");
job.BlockTemplate.ReservedOffset.ShouldBeEquivalentTo(129);
job.BlockTemplate.Status.ShouldBeEquivalentTo("OK");
job.BlockTemplate.Blob.Should().Be("07079ccdc1d3053b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b0000000002e3b64201ffa7b64201b3be90f18de9010258f3cdf062d631c578597ad4aa00bb6e99bbbdc816fa295286ea956c2d15e1cf2b0109d8ec8c47fb41668d69ef2ce3764a906285bbab66a127247f627b939380ddc7020800000000000000000000");
job.BlockTemplate.Difficulty.Should().Be(23096);
job.BlockTemplate.Height.Should().Be(1088295);
job.BlockTemplate.PreviousBlockhash.Should().Be("3b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b");
job.BlockTemplate.ReservedOffset.Should().Be(129);
job.BlockTemplate.Status.Should().Be("OK");
});

// check the second job
await _jobManager.JobQueue.Take(1).Do(job =>
{
job.BlockTemplate.Blob.ShouldBeEquivalentTo("0707b0cfc1d305a6a0d38480cde292cbcd372835fb8d57ff8285b5334c724f610599d379c5499d0000000002e4b64201ffa8b64201ee86ece98de90102d287d0af34a8c9dc624cf4a7495f673782d9a323b1d22dec71b069af84c072672b013b54f7d869b695fd5e5fa05ddf49e971f511440b86ff42ce836283d207777442020800000000000000000000");
job.BlockTemplate.Difficulty.ShouldBeEquivalentTo(23087);
job.BlockTemplate.Height.ShouldBeEquivalentTo(1088296);
job.BlockTemplate.PreviousBlockhash.ShouldBeEquivalentTo("a6a0d38480cde292cbcd372835fb8d57ff8285b5334c724f610599d379c5499d");
job.BlockTemplate.ReservedOffset.ShouldBeEquivalentTo(129);
job.BlockTemplate.Status.ShouldBeEquivalentTo("OK");
job.BlockTemplate.Blob.Should().Be("0707b0cfc1d305a6a0d38480cde292cbcd372835fb8d57ff8285b5334c724f610599d379c5499d0000000002e4b64201ffa8b64201ee86ece98de90102d287d0af34a8c9dc624cf4a7495f673782d9a323b1d22dec71b069af84c072672b013b54f7d869b695fd5e5fa05ddf49e971f511440b86ff42ce836283d207777442020800000000000000000000");
job.BlockTemplate.Difficulty.Should().Be(23087);
job.BlockTemplate.Height.Should().Be(1088296);
job.BlockTemplate.PreviousBlockhash.Should().Be("a6a0d38480cde292cbcd372835fb8d57ff8285b5334c724f610599d379c5499d");
job.BlockTemplate.ReservedOffset.Should().Be(129);
job.BlockTemplate.Status.Should().Be("OK");
});
}

@@ -108,17 +108,17 @@ public async void ShouldNotGetANewJobOnSameBlockTemplate()
// check first response.
await _jobManager.JobQueue.Take(1).Do(job =>
{
job.BlockTemplate.Blob.ShouldBeEquivalentTo("07079ccdc1d3053b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b0000000002e3b64201ffa7b64201b3be90f18de9010258f3cdf062d631c578597ad4aa00bb6e99bbbdc816fa295286ea956c2d15e1cf2b0109d8ec8c47fb41668d69ef2ce3764a906285bbab66a127247f627b939380ddc7020800000000000000000000");
job.BlockTemplate.Difficulty.ShouldBeEquivalentTo(23096);
job.BlockTemplate.Height.ShouldBeEquivalentTo(1088295);
job.BlockTemplate.PreviousBlockhash.ShouldBeEquivalentTo("3b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b");
job.BlockTemplate.ReservedOffset.ShouldBeEquivalentTo(129);
job.BlockTemplate.Status.ShouldBeEquivalentTo("OK");
job.BlockTemplate.Blob.Should().Be("07079ccdc1d3053b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b0000000002e3b64201ffa7b64201b3be90f18de9010258f3cdf062d631c578597ad4aa00bb6e99bbbdc816fa295286ea956c2d15e1cf2b0109d8ec8c47fb41668d69ef2ce3764a906285bbab66a127247f627b939380ddc7020800000000000000000000");
job.BlockTemplate.Difficulty.Should().Be(23096);
job.BlockTemplate.Height.Should().Be(1088295);
job.BlockTemplate.PreviousBlockhash.Should().Be("3b4aff4fdac0424b58a69234796f1e572eea2650cb4a6c19aa03c17308d73d5b");
job.BlockTemplate.ReservedOffset.Should().Be(129);
job.BlockTemplate.Status.Should().Be("OK");
});

// we should not even get a second job as daemon will just reply with same blocktemplates.
Func<Task> call = async () => { await _jobManager.JobQueue.Take(1).Timeout(TimeSpan.FromMilliseconds(100)); };
call.ShouldThrow<TimeoutException>(); // as we won't get a new job, the call should timeout with an expection..
call.Should().Throw<TimeoutException>(); // as we won't get a new job, the call should timeout with an expection..
}
}