WrapHelper2< TLeftKey, TRightKey >()

void System.Linq.Parallel.ConcatQueryOperator< TSource >.WrapHelper2< TLeftKey, TRightKey > ( PartitionedStream< TSource, TLeftKey > leftStreamInc, PartitionedStream< TSource, TRightKey > rightStreamInc, IPartitionedStreamRecipient< TSource > outputRecipient )

inlineprivate

Definition at line 144 of file ConcatQueryOperator.cs.

    {
        int partitionCount = leftStreamInc.PartitionCount;
        IComparer<ConcatKey<TLeftKey, TRightKey>> keyComparer = ConcatKey<TLeftKey, TRightKey>.MakeComparer(leftStreamInc.KeyComparer, rightStreamInc.KeyComparer);
        PartitionedStream<TSource, ConcatKey<TLeftKey, TRightKey>> partitionedStream = new PartitionedStream<TSource, ConcatKey<TLeftKey, TRightKey>>(partitionCount, keyComparer, OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new ConcatQueryOperatorEnumerator<TLeftKey, TRightKey>(leftStreamInc[i], rightStreamInc[i]);
        }
        outputRecipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.BinaryQueryOperator< TSource, TSource, TSource >.OrdinalIndexState.