WrapHelper< TKey >()

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

inlineprivate

Definition at line 214 of file TakeOrSkipQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        FixedMaxHeap<TKey> sharedIndices = new FixedMaxHeap<TKey>(_count, inputStream.KeyComparer);
        CountdownEvent sharedBarrier = new CountdownEvent(partitionCount);
        PartitionedStream<TResult, TKey> partitionedStream = new PartitionedStream<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new TakeOrSkipQueryOperatorEnumerator<TKey>(inputStream[i], _take, sharedIndices, sharedBarrier, settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.TakeOrSkipQueryOperator< TResult >._count, System.Linq.Parallel.TakeOrSkipQueryOperator< TResult >._take, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.