OutputAvailableAsync< TOutput >() [2/2]

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

inlinestatic

Definition at line 1465 of file DataflowBlock.cs.

    {
        if (source == null)
        {
            throw new ArgumentNullException("source");
        }
        if (cancellationToken.IsCancellationRequested)
        {
            return Common.CreateTaskFromCancellation<bool>(cancellationToken);
        }
        OutputAvailableAsyncTarget<TOutput> outputAvailableAsyncTarget = new OutputAvailableAsyncTarget<TOutput>();
        try
        {
            outputAvailableAsyncTarget._unlinker = source.LinkTo(outputAvailableAsyncTarget, DataflowLinkOptions.UnlinkAfterOneAndPropagateCompletion);
            if (outputAvailableAsyncTarget.Task.IsCompleted)
            {
                return outputAvailableAsyncTarget.Task;
            }
            if (cancellationToken.CanBeCanceled)
            {
                outputAvailableAsyncTarget._ctr = cancellationToken.Register(OutputAvailableAsyncTarget<TOutput>.s_cancelAndUnlink, outputAvailableAsyncTarget);
            }
            return outputAvailableAsyncTarget.Task.ContinueWith(OutputAvailableAsyncTarget<TOutput>.s_handleCompletion, outputAvailableAsyncTarget, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.NotOnCanceled, TaskScheduler.Default);
        }
        catch (Exception exception)
        {
            outputAvailableAsyncTarget.TrySetException(exception);
            outputAvailableAsyncTarget.AttemptThreadSafeUnlink();
            return outputAvailableAsyncTarget.Task;
        }
    }

References System.cancellationToken, System.Threading.Tasks.TaskScheduler.Default, System.exception, System.Threading.Tasks.Dataflow.Internal.Common.GetContinuationOptions(), System.Threading.CancellationToken.None, System.source, and System.Threading.Tasks.Dataflow.DataflowLinkOptions.UnlinkAfterOneAndPropagateCompletion.