3 writes to _channelEnumerator
System.Linq.Parallel (3)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (3)
70_channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(_taskGroupState, _asyncChannels, consumerEvent); 76_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], _taskGroupState.CancellationState).GetEnumerator(); 83_channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(_taskGroupState, _syncChannels);
3 references to _channelEnumerator
System.Linq.Parallel (3)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (3)
88Debug.Assert(_channelEnumerator != null, "enumerator can't be null if we're not ignoring output"); 128Debug.Assert(_ignoreOutput || _channelEnumerator != null); 129return _channelEnumerator!;