MakeAsynchronousChannels()

static AsynchronousChannel< TInputOutput >[] System.Linq.Parallel.MergeExecutor< TInputOutput >.MakeAsynchronousChannels ( int partitionCount, ParallelMergeOptions options, IntValueEvent consumerEvent, CancellationToken cancellationToken )

inlinestaticpackage

Definition at line 66 of file MergeExecutor.cs.

    {
        AsynchronousChannel<TInputOutput>[] array = new AsynchronousChannel<TInputOutput>[partitionCount];
        int chunkSize = 0;
        if (options == ParallelMergeOptions.NotBuffered)
        {
            chunkSize = 1;
        }
        for (int i = 0; i < array.Length; i++)
        {
            array[i] = new AsynchronousChannel<TInputOutput>(i, chunkSize, cancellationToken, consumerEvent);
        }
        return array;
    }

References System.array, System.cancellationToken, and System.options.