ReceiveCore< TOutput >()

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

inlinestaticprivate

Definition at line 1400 of file DataflowBlock.cs.

    {
        if (cancellationToken.IsCancellationRequested)
        {
            return Common.CreateTaskFromCancellation<TOutput>(cancellationToken);
        }
        if (attemptTryReceive && source is IReceivableSourceBlock<TOutput> receivableSourceBlock)
        {
            try
            {
                if (receivableSourceBlock.TryReceive(null, out var item))
                {
                    return Task.FromResult(item);
                }
            }
            catch (Exception exception)
            {
                return Common.CreateTaskFromException<TOutput>(exception);
            }
        }
        int num = (int)timeout.TotalMilliseconds;
        if (num == 0)
        {
            return Common.CreateTaskFromException<TOutput>(ReceiveTarget<TOutput>.CreateExceptionForTimeout());
        }
        return ReceiveCoreByLinking(source, num, cancellationToken);
    }

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