ReceiveCoreByLinking< TOutput >()

static Task< TOutput > System.Threading.Tasks.Dataflow.DataflowBlock.ReceiveCoreByLinking< TOutput > ( ISourceBlock< TOutput > source, int millisecondsTimeout, CancellationToken cancellationToken )

inlinestaticprivate

Definition at line 1428 of file DataflowBlock.cs.

    {
        ReceiveTarget<TOutput> receiveTarget = new ReceiveTarget<TOutput>();
        try
        {
            if (cancellationToken.CanBeCanceled)
            {
                receiveTarget._externalCancellationToken = cancellationToken;
                receiveTarget._regFromExternalCancellationToken = cancellationToken.Register(_cancelCts, receiveTarget._cts);
            }
            if (millisecondsTimeout > 0)
            {
                receiveTarget._timer = new Timer(ReceiveTarget<TOutput>.CachedLinkingTimerCallback, receiveTarget, millisecondsTimeout, -1);
            }
            if (receiveTarget._cts.Token.CanBeCanceled)
            {
                receiveTarget._cts.Token.Register(ReceiveTarget<TOutput>.CachedLinkingCancellationCallback, receiveTarget);
            }
            IDisposable comparand = (receiveTarget._unlink = source.LinkTo(receiveTarget, DataflowLinkOptions.UnlinkAfterOneAndPropagateCompletion));
            if (Volatile.Read(ref receiveTarget._cleanupReserved))
            {
                Interlocked.CompareExchange(ref receiveTarget._unlink, null, comparand)?.Dispose();
            }
        }
        catch (Exception receivedException)
        {
            receiveTarget._receivedException = receivedException;
            receiveTarget.TryCleanupAndComplete(ReceiveCoreByLinkingCleanupReason.SourceProtocolError);
        }
        return receiveTarget.Task;
    }

References System.Threading.Tasks.Dataflow.DataflowBlock._cancelCts, System.cancellationToken, System.Threading.Interlocked.CompareExchange(), System.millisecondsTimeout, System.Threading.Volatile.Read(), System.source, System.Threading.Tasks.Dataflow.DataflowBlock.Timer, and System.Threading.Tasks.Dataflow.DataflowLinkOptions.UnlinkAfterOneAndPropagateCompletion.