WrapPartitionedStreamIndexed()

void System.Linq.Parallel.SelectManyQueryOperator< TLeftInput, TRightInput, TOutput >.WrapPartitionedStreamIndexed ( PartitionedStream< TLeftInput, int > inputStream, IPartitionedStreamRecipient< TOutput > recipient, QuerySettings settings )

inlineprivate

Definition at line 256 of file SelectManyQueryOperator.cs.

    {
        PairComparer<int, int> keyComparer = new PairComparer<int, int>(inputStream.KeyComparer, Util.GetDefaultComparer<int>());
        PartitionedStream<TOutput, Pair<int, int>> partitionedStream = new PartitionedStream<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState);
        for (int i = 0; i < inputStream.PartitionCount; i++)
        {
            partitionedStream[i] = new IndexedSelectManyQueryOperatorEnumerator(inputStream[i], this, settings.CancellationState.MergedCancellationToken);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.QuerySettings.CancellationState, System.Linq.Parallel.CancellationState.MergedCancellationToken, and System.Linq.Parallel.UnaryQueryOperator< TLeftInput, TOutput >.OrdinalIndexState.

Referenced by System.Linq.Parallel.SelectManyQueryOperator< TLeftInput, TRightInput, TOutput >.WrapPartitionedStream< TLeftKey >().