Skip to content

Commit 9117a9a

Browse files
committed
- using cancellation token / not source
1 parent 08faf5c commit 9117a9a

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

Shuttle.Core.Threading/ThreadState.cs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,11 @@ namespace Shuttle.Core.Threading
77
public class ThreadState : IThreadState
88
{
99
private readonly Func<bool> _state;
10-
private readonly CancellationTokenSource _cancellationTokenSource;
10+
private readonly CancellationToken _cancellationToken;
1111

12-
public ThreadState(CancellationTokenSource cancellationTokenSource)
12+
public ThreadState(CancellationToken cancellationToken)
1313
{
14-
Guard.AgainstNull(cancellationTokenSource, nameof(cancellationTokenSource));
15-
16-
_cancellationTokenSource = cancellationTokenSource;
14+
_cancellationToken = cancellationToken;
1715
}
1816

1917
public ThreadState(Func<bool> state)
@@ -23,6 +21,6 @@ public ThreadState(Func<bool> state)
2321
_state = state;
2422
}
2523

26-
public bool Active => _cancellationTokenSource?.IsCancellationRequested ?? _state.Invoke();
24+
public bool Active => _state?.Invoke() ?? _cancellationToken.IsCancellationRequested;
2725
}
2826
}

0 commit comments

Comments
 (0)