WrapHelper< TKey >()

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

inlineprivate

Definition at line 208 of file TakeOrSkipWhileQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        OperatorState<TKey> operatorState = new OperatorState<TKey>();
        CountdownEvent sharedBarrier = new CountdownEvent(partitionCount);
        Func<TResult, TKey, bool> indexedPredicate = (Func<TResult, TKey, bool>)(object)_indexedPredicate;
        PartitionedStream<TResult, TKey> partitionedStream = new PartitionedStream<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new TakeOrSkipWhileQueryOperatorEnumerator<TKey>(inputStream[i], _predicate, indexedPredicate, _take, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.TakeOrSkipWhileQueryOperator< TResult >._indexedPredicate, System.Linq.Parallel.TakeOrSkipWhileQueryOperator< TResult >._predicate, System.Linq.Parallel.TakeOrSkipWhileQueryOperator< TResult >._take, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.