WrapPartitionedStream< TKey >() [2/2]

override void System.Linq.Parallel.TakeOrSkipQueryOperator< TResult >.WrapPartitionedStream< TKey > ( PartitionedStream< TResult, TKey > inputStream, IPartitionedStreamRecipient< TResult > recipient, bool preferStriping, QuerySettings settings )

inlinepackage

Definition at line 200 of file TakeOrSkipQueryOperator.cs.

    {
        if (_prematureMerge)
        {
            ListQueryResults<TResult> listQueryResults = QueryOperator<TResult>.ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, base.Child.OutputOrdered, preferStriping, settings);
            PartitionedStream<TResult, int> partitionedStream = listQueryResults.GetPartitionedStream();
            WrapHelper(partitionedStream, recipient, settings);
        }
        else
        {
            WrapHelper(inputStream, recipient, settings);
        }
    }

References System.Linq.Parallel.TakeOrSkipQueryOperator< TResult >._prematureMerge.