1 write to _op
System.Linq.Parallel (1)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
103_op = op;
4 references to _op
System.Linq.Parallel (4)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (4)
110Debug.Assert(IsIndexible == (_op.OrdinalIndexState == OrdinalIndexState.Indexable)); 113if (_settings.ExecutionMode.Value == ParallelExecutionMode.Default && _op.LimitsParallelism) 116IEnumerable<TOutput> opSequential = _op.AsSequentialQuery(_settings.CancellationState.ExternalCancellationToken); 130_childQueryResults.GivePartitionedStream(new ChildResultsRecipient(recipient, _op, _preferStriping, _settings));