WrapPartitionedStream< TLeftKey, TRightKey >() [1/2]

override void System.Linq.Parallel.IntersectQueryOperator< TInputOutput >.WrapPartitionedStream< TLeftKey, TRightKey > ( PartitionedStream< TInputOutput, TLeftKey > leftPartitionedStream, PartitionedStream< TInputOutput, TRightKey > rightPartitionedStream, IPartitionedStreamRecipient< TInputOutput > outputRecipient, bool preferStriping, QuerySettings settings )

inline

Definition at line 163 of file IntersectQueryOperator.cs.

    {
        if (base.OutputOrdered)
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TLeftKey>(leftPartitionedStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
        }
        else
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TLeftKey>(leftPartitionedStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
        }
    }

References System.Linq.Parallel.IntersectQueryOperator< TInputOutput >._comparer, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.