WrapHelper< TKey >()

void System.Linq.Parallel.LastQueryOperator< TSource >.WrapHelper< TKey > ( PartitionedStream< TSource, TKey > inputStream, IPartitionedStreamRecipient< TSource > recipient, QuerySettings settings )

inlineprivate

Definition at line 141 of file LastQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        LastQueryOperatorState<TKey> operatorState = new LastQueryOperatorState<TKey>();
        CountdownEvent sharedBarrier = new CountdownEvent(partitionCount);
        PartitionedStream<TSource, int> partitionedStream = new PartitionedStream<TSource, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Shuffled);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new LastQueryOperatorEnumerator<TKey>(inputStream[i], _predicate, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer, i);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.LastQueryOperator< TSource >._predicate, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.