Receive< TOutput >() [4/4]

static TOutput System.Threading.Tasks.Dataflow.DataflowBlock.Receive< TOutput > ( this ISourceBlock< TOutput > source, TimeSpan timeout, CancellationToken cancellationToken )

inlinestatic

Definition at line 1370 of file DataflowBlock.cs.

    {
        if (source == null)
        {
            throw new ArgumentNullException("source");
        }
        if (!Common.IsValidTimeout(timeout))
        {
            throw new ArgumentOutOfRangeException("timeout", System.SR.ArgumentOutOfRange_NeedNonNegOrNegative1);
        }
        cancellationToken.ThrowIfCancellationRequested();
        if (source is IReceivableSourceBlock<TOutput> receivableSourceBlock && receivableSourceBlock.TryReceive(null, out var item))
        {
            return item;
        }
        Task<TOutput> task = source.ReceiveCore(attemptTryReceive: false, timeout, cancellationToken);
        try
        {
            return task.GetAwaiter().GetResult();
        }
        catch
        {
            if (task.IsCanceled)
            {
                cancellationToken.ThrowIfCancellationRequested();
            }
            throw;
        }
    }

References System.SR.ArgumentOutOfRange_NeedNonNegOrNegative1, System.cancellationToken, System.Threading.Tasks.Dataflow.Internal.Common.IsValidTimeout(), System.item, System.source, System.task, and System.timeout.