◆ Open()

override QueryResults< TOutput > System.Linq.Parallel.ZipQueryOperator< TLeftInput, TRightInput, TOutput >.Open	(	QuerySettings	settings,
		bool	preferStriping )

inlinepackage

Definition at line 83 of file ZipQueryOperator.cs.

    {
        QueryResults<TLeftInput> queryResults = _leftChild.Open(settings, preferStriping);
        QueryResults<TRightInput> queryResults2 = _rightChild.Open(settings, preferStriping);
        int value = settings.DegreeOfParallelism.Value;
        if (_prematureMergeLeft)
        {
            PartitionedStreamMerger<TLeftInput> partitionedStreamMerger = new PartitionedStreamMerger<TLeftInput>(forEffectMerge: false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, _leftChild.OutputOrdered, settings.CancellationState, settings.QueryId);
            queryResults.GivePartitionedStream(partitionedStreamMerger);
            queryResults = new ListQueryResults<TLeftInput>(partitionedStreamMerger.MergeExecutor.GetResultsAsArray(), value, preferStriping);
        }
        if (_prematureMergeRight)
        {
            PartitionedStreamMerger<TRightInput> partitionedStreamMerger2 = new PartitionedStreamMerger<TRightInput>(forEffectMerge: false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, _rightChild.OutputOrdered, settings.CancellationState, settings.QueryId);
            queryResults2.GivePartitionedStream(partitionedStreamMerger2);
            queryResults2 = new ListQueryResults<TRightInput>(partitionedStreamMerger2.MergeExecutor.GetResultsAsArray(), value, preferStriping);
        }
        return new ZipQueryOperatorResults(queryResults, queryResults2, _resultSelector, value, preferStriping);
    }