WrapPartitionedStream< TKey >() [2/2]

override void System.Linq.Parallel.DefaultIfEmptyQueryOperator< TSource >.WrapPartitionedStream< TKey > ( PartitionedStream< TSource, TKey > inputStream, IPartitionedStreamRecipient< TSource > recipient, bool preferStriping, QuerySettings settings )

inlinepackage

Definition at line 91 of file DefaultIfEmptyQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        Shared<int> sharedEmptyCount = new Shared<int>(0);
        CountdownEvent sharedLatch = new CountdownEvent(partitionCount - 1);
        PartitionedStream<TSource, TKey> partitionedStream = new PartitionedStream<TSource, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new DefaultIfEmptyQueryOperatorEnumerator<TKey>(inputStream[i], _defaultValue, i, partitionCount, sharedEmptyCount, sharedLatch, settings.CancellationState.MergedCancellationToken);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.DefaultIfEmptyQueryOperator< TSource >._defaultValue, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.