1 write to _asyncChannels
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
68
_asyncChannels
=
5 references to _asyncChannels
System.Linq.Parallel (5)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (5)
70
_channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(_taskGroupState,
_asyncChannels
, consumerEvent);
86
Debug.Assert(
_asyncChannels
== null ||
_asyncChannels
.Length == partitions.PartitionCount);
101
if (
_asyncChannels
!= null)
104
SpoolingTask.SpoolPipeline<TInputOutput, TIgnoreKey>(_taskGroupState, _partitions,
_asyncChannels
, _taskScheduler);