WrapPartitionedStream< TKey >() [2/2]

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

inlinepackage

Definition at line 81 of file ElementAtQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        PartitionedStream<TSource, int> partitionedStream = ((!_prematureMerge) ? ((PartitionedStream<TSource, int>)(object)inputStream) : QueryOperator<TSource>.ExecuteAndCollectResults(inputStream, partitionCount, base.Child.OutputOrdered, preferStriping, settings).GetPartitionedStream());
        Shared<bool> resultFoundFlag = new Shared<bool>(value: false);
        PartitionedStream<TSource, int> partitionedStream2 = new PartitionedStream<TSource, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream2[i] = new ElementAtQueryOperatorEnumerator(partitionedStream[i], _index, resultFoundFlag, settings.CancellationState.MergedCancellationToken);
        }
        recipient.Receive(partitionedStream2);
    }

References System.Linq.Parallel.ElementAtQueryOperator< TSource >._index, System.Linq.Parallel.ElementAtQueryOperator< TSource >._prematureMerge, System.Linq.Parallel.QuerySettings.CancellationState, System.Linq.Parallel.CancellationState.MergedCancellationToken, and System.value.