ReceiveAllAsync< TOutput >()

static IAsyncEnumerable< TOutput > System.Threading.Tasks.Dataflow.DataflowBlock.ReceiveAllAsync< TOutput > ( this IReceivableSourceBlock< TOutput > source, CancellationToken cancellationToken = default(CancellationToken) )

inlinestatic

Definition at line 1723 of file DataflowBlock.cs.

    {
        if (source == null)
        {
            throw new ArgumentNullException("source");
        }
        return ReceiveAllAsyncCore(source, cancellationToken);
        static async IAsyncEnumerable<TOutput> ReceiveAllAsyncCore(IReceivableSourceBlock<TOutput> source, [EnumeratorCancellation] CancellationToken cancellationToken)
        {
            while (await source.OutputAvailableAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false))
            {
                TOutput item;
                while (source.TryReceive(out item))
                {
                    yield return item;
                }
            }
        }
    }

References System.cancellationToken, System.item, and System.source.