SendAsync< TInput >() [2/2]

static Task< bool > System.Threading.Tasks.Dataflow.DataflowBlock.SendAsync< TInput > ( this ITargetBlock< TInput > target, TInput item, CancellationToken cancellationToken )

inlinestatic

Definition at line 1285 of file DataflowBlock.cs.

    {
        if (target == null)
        {
            throw new ArgumentNullException("target");
        }
        if (cancellationToken.IsCancellationRequested)
        {
            return Common.CreateTaskFromCancellation<bool>(cancellationToken);
        }
        SendAsyncSource<TInput> sendAsyncSource;
        try
        {
            switch (target.OfferMessage(Common.SingleMessageHeader, item, null, consumeToAccept: false))
            {
            case DataflowMessageStatus.Accepted:
                return Common.CompletedTaskWithTrueResult;
            case DataflowMessageStatus.DecliningPermanently:
                return Common.CompletedTaskWithFalseResult;
            default:
                sendAsyncSource = new SendAsyncSource<TInput>(target, item, cancellationToken);
                break;
            }
        }
        catch (Exception ex)
        {
            Common.StoreDataflowMessageValueIntoExceptionData(ex, item);
            return Common.CreateTaskFromException<bool>(ex);
        }
        sendAsyncSource.OfferToTarget();
        return sendAsyncSource.Task;
    }

References System.cancellationToken, System.Threading.Tasks.Dataflow.Internal.Common.CompletedTaskWithFalseResult, System.Threading.Tasks.Dataflow.Internal.Common.CompletedTaskWithTrueResult, System.item, and System.Threading.Tasks.Dataflow.Internal.Common.SingleMessageHeader.