WrapPartitionedStream< TKey >() [1/2]

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

inlinepackage

Definition at line 116 of file ContainsSearchOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        PartitionedStream<bool, int> partitionedStream = new PartitionedStream<bool, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);
        Shared<bool> resultFoundFlag = new Shared<bool>(value: false);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream[i] = new ContainsSearchOperatorEnumerator<TKey>(inputStream[i], _searchValue, _comparer, i, resultFoundFlag, settings.CancellationState.MergedCancellationToken);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.ContainsSearchOperator< TInput >._comparer, System.Linq.Parallel.ContainsSearchOperator< TInput >._searchValue, System.Linq.Parallel.QuerySettings.CancellationState, System.Linq.Parallel.CancellationState.MergedCancellationToken, and System.value.