34 references to Wrap
System.Linq.Parallel (34)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)
116
IEnumerable<TInputOutput> wrappedLeftChild = CancellableEnumerable.
Wrap
(LeftChild.AsSequentialQuery(token), token);
117
IEnumerable<TInputOutput> wrappedRightChild = CancellableEnumerable.
Wrap
(RightChild.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (2)
192
IEnumerable<TLeftInput> wrappedLeftChild = CancellableEnumerable.
Wrap
(LeftChild.AsSequentialQuery(token), token);
193
IEnumerable<TRightInput> wrappedRightChild = CancellableEnumerable.
Wrap
(RightChild.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)
222
IEnumerable<TInputOutput> wrappedLeftChild = CancellableEnumerable.
Wrap
(LeftChild.AsSequentialQuery(token), token);
223
IEnumerable<TInputOutput> wrappedRightChild = CancellableEnumerable.
Wrap
(RightChild.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (2)
170
IEnumerable<TLeftInput> wrappedLeftChild = CancellableEnumerable.
Wrap
(LeftChild.AsSequentialQuery(token), token);
171
IEnumerable<TRightInput> wrappedRightChild = CancellableEnumerable.
Wrap
(RightChild.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
162
IEnumerable<TInputOutput> wrappedLeftChild = CancellableEnumerable.
Wrap
(LeftChild.AsSequentialQuery(token), token);
163
IEnumerable<TInputOutput> wrappedRightChild = CancellableEnumerable.
Wrap
(RightChild.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
204
IEnumerable<TOutput> opSequentialWithCancelChecks = CancellableEnumerable.
Wrap
(opSequential, querySettings.CancellationState.ExternalCancellationToken);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
187
IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (2)
135
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, cancelState.ExternalCancellationToken);
141
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, cancelState.ExternalCancellationToken);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (1)
189
IEnumerable<TSource> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
120
IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)
86
IEnumerable<TSource> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (4)
202
return CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token).SelectMany(_rightChildSelector, _resultSelector);
204
return (IEnumerable<TOutput>)CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token).SelectMany(_rightChildSelector);
211
return CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token).SelectMany(_indexedRightChildSelector, _resultSelector);
214
return (IEnumerable<TOutput>)CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token).SelectMany(_indexedRightChildSelector);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
104
IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
324
IEnumerable<TResult> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)
182
IEnumerable<TResult> wrappedIndexedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
187
IEnumerable<TResult> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
84
IEnumerable<TInputOutput> wrappedChild = CancellableEnumerable.
Wrap
(Child.AsSequentialQuery(token), token);
System\Linq\ParallelEnumerable.cs (8)
5409
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5451
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5492
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5537
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5586
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5628
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5670
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5711
IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.
Wrap
(childAsSequential, settings.CancellationState.ExternalCancellationToken);