CancellationToken

3 writes to CancellationToken

System.Threading.Tasks.Dataflow (3)

Base\DataflowBlockOptions.cs (3)

96CancellationToken = this.CancellationToken, 267CancellationToken = this.CancellationToken, 399CancellationToken = this.CancellationToken,

36 references to CancellationToken

System.Threading.Tasks.Dataflow (36)

Base\DataflowBlock.cs (4)

1832if (dataflowBlockOptions.CancellationToken.IsCancellationRequested) 1833return Common.CreateTaskFromCancellation<int>(dataflowBlockOptions.CancellationToken); 1923CancellationTokenSource cts = CancellationTokenSource.CreateLinkedTokenSource(dataflowBlockOptions.CancellationToken, CancellationToken.None); 1982result.TrySetCanceled(dataflowBlockOptions.CancellationToken);

Base\DataflowBlockOptions.cs (3)

96CancellationToken = this.CancellationToken, 267CancellationToken = this.CancellationToken, 399CancellationToken = this.CancellationToken,

Blocks\ActionBlock.cs (2)

83!dataflowBlockOptions.CancellationToken.CanBeCanceled && 114dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _defaultTarget);

Blocks\BatchBlock.cs (3)

90dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchBlockTargetCore)state!).Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false), _target); 332if (!_decliningPermanently && !_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 480return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _owningBatch._source.HasExceptions;

Blocks\BatchedJoinBlock.cs (2)

108dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2>)state!).CompleteEachTarget(), this); 357dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this);

Blocks\BroadcastBlock.cs (4)

97dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BroadcastBlock<T>)state!).Complete(), this); 983else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 985_completionTask.TrySetCanceled(_dataflowBlockOptions.CancellationToken); 1141return _dataflowBlockOptions.CancellationToken.IsCancellationRequested ||

Blocks\BufferBlock.cs (1)

79dataflowBlockOptions.CancellationToken, _source.Completion, static (owningSource, _) => ((BufferBlock<T>)owningSource!).Complete(), this);

Blocks\JoinBlock.cs (3)

101dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2>)state!)._sharedResources.CompleteEachTarget(), this); 320dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2, T3>)state!)._sharedResources.CompleteEachTarget(), this); 1224return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _hasExceptions;

Blocks\TransformBlock.cs (1)

160dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _target);

Blocks\TransformManyBlock.cs (1)

159dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), target);

Blocks\WriteOnceBlock.cs (6)

78if (dataflowBlockOptions.CancellationToken.CanBeCanceled) 84if (dataflowBlockOptions.CancellationToken.IsCancellationRequested) 89_lazyCompletionTaskSource.TrySetCanceled(dataflowBlockOptions.CancellationToken); 95dataflowBlockOptions.CancellationToken, _lazyCompletionTaskSource.Task, static (state, _) => ((WriteOnceBlock<T>)state!).Complete(), this); 180else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 182CompletionTaskSource.TrySetCanceled(_dataflowBlockOptions.CancellationToken);

Internal\SourceCore.cs (3)

878return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || 957else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 959_completionTask.TrySetCanceled(_dataflowBlockOptions.CancellationToken);

Internal\TargetCore.cs (3)

708return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || Volatile.Read(ref _exceptions) != null; 784else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 786_completionSource.TrySetCanceled(_dataflowBlockOptions.CancellationToken);