SpoolingWork()

override void System.Linq.Parallel.PipelineSpoolingTask< TInputOutput, TIgnoreKey >.SpoolingWork ( )

inlineprotected

Definition at line 18 of file PipelineSpoolingTask.cs.

    {
        TInputOutput currentElement = default(TInputOutput);
        TIgnoreKey currentKey = default(TIgnoreKey);
        QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source = _source;
        AsynchronousChannel<TInputOutput> destination = _destination;
        CancellationToken mergedCancellationToken = _groupState.CancellationState.MergedCancellationToken;
        while (source.MoveNext(ref currentElement, ref currentKey) && !mergedCancellationToken.IsCancellationRequested)
        {
            destination.Enqueue(currentElement);
        }
        destination.FlushBuffers();
    }

References System.Linq.Parallel.PipelineSpoolingTask< TInputOutput, TIgnoreKey >._destination, System.Linq.Parallel.QueryTask._groupState, System.Linq.Parallel.PipelineSpoolingTask< TInputOutput, TIgnoreKey >._source, System.Linq.Parallel.QueryTaskGroupState.CancellationState, System.destination, System.Threading.CancellationToken.IsCancellationRequested, System.Linq.Parallel.CancellationState.MergedCancellationToken, and System.Linq.source.