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

override void System.Linq.Parallel.ExceptQueryOperator< TInputOutput >.WrapPartitionedStream< TLeftKey, TRightKey > ( PartitionedStream< TInputOutput, TLeftKey > leftStream, PartitionedStream< TInputOutput, TRightKey > rightStream, IPartitionedStreamRecipient< TInputOutput > outputRecipient, bool preferStriping, QuerySettings settings )

inline

Definition at line 168 of file ExceptQueryOperator.cs.

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

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