WrapHelper< TKey >()

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

inlineprivate

Definition at line 137 of file FirstQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        FirstQueryOperatorState<TKey> operatorState = new FirstQueryOperatorState<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 FirstQueryOperatorEnumerator<TKey>(inputStream[i], _predicate, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer, i);
        }
        recipient.Receive(partitionedStream);
    }

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