GetConsumingEnumerable() [2/2]

IEnumerable< T > System.Collections.Concurrent.BlockingCollection< T >.GetConsumingEnumerable ( CancellationToken cancellationToken )

inline

Definition at line 739 of file BlockingCollection.cs.

    {
        CancellationTokenSource linkedTokenSource = null;
        try
        {
            linkedTokenSource = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, _consumersCancellationTokenSource.Token);
            while (!IsCompleted)
            {
                if (TryTakeWithNoTimeValidation(out var item, -1, cancellationToken, linkedTokenSource))
                {
                    yield return item;
                }
            }
        }
        finally
        {
            linkedTokenSource?.Dispose();
        }
    }

References System.Collections.Concurrent.BlockingCollection< T >._consumersCancellationTokenSource, System.cancellationToken, System.Threading.CancellationTokenSource.CreateLinkedTokenSource(), System.Collections.Concurrent.BlockingCollection< T >.IsCompleted, System.item, System.Threading.CancellationTokenSource.Token, and System.Collections.Concurrent.BlockingCollection< T >.TryTakeWithNoTimeValidation().