3 writes to m_channelEnumerator
System.Core (3)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (3)
73m_channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(m_taskGroupState, m_asyncChannels, consumerEvent); 79m_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], m_taskGroupState.CancellationState).GetEnumerator(); 86m_channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(m_taskGroupState, m_syncChannels);
3 references to m_channelEnumerator
System.Core (3)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (3)
91Contract.Assert(m_channelEnumerator != null, "enumerator can't be null if we're not ignoring output"); 130Contract.Assert(m_ignoreOutput || m_channelEnumerator != null); 131return m_channelEnumerator;