WrapPartitionedStream< TKey >()

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

inlinepackage

Definition at line 81 of file SelectQueryOperator.cs.

    {
        PartitionedStream<TOutput, TKey> partitionedStream = new PartitionedStream<TOutput, TKey>(inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState);
        for (int i = 0; i < inputStream.PartitionCount; i++)
        {
            partitionedStream[i] = new SelectQueryOperatorEnumerator<TKey>(inputStream[i], _selector);
        }
        recipient.Receive(partitionedStream);
    }

References System.Linq.Parallel.SelectQueryOperator< TInput, TOutput >._selector.