1 write to m_asyncChannels
System.Core (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
71
m_asyncChannels
=
5 references to m_asyncChannels
System.Core (5)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (5)
73
m_channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(m_taskGroupState,
m_asyncChannels
, consumerEvent);
89
Contract.Assert(
m_asyncChannels
== null ||
m_asyncChannels
.Length == partitions.PartitionCount);
104
if (
m_asyncChannels
!= null)
106
SpoolingTask.SpoolPipeline<TInputOutput, TIgnoreKey>(m_taskGroupState, m_partitions,
m_asyncChannels
, m_taskScheduler);