1 instantiation of SendAsyncSource
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
349source = new SendAsyncSource<TInput>(target, item, cancellationToken);
15 references to SendAsyncSource
System.Threading.Tasks.Dataflow (15)
Base\DataflowBlock.cs (15)
318SendAsyncSource<TInput> source; 368[DebuggerTypeProxy(typeof(SendAsyncSource<>.DebugView))] 430_cancellationCallback, new WeakReference<SendAsyncSource<TOutput>>(this)); 461try { ((SendAsyncSource<TOutput>)state!).TrySetResult(true); } 474try { ((SendAsyncSource<TOutput>)state!).TrySetResult(false); } 486var tuple = (Tuple<SendAsyncSource<TOutput>, Exception>)state!; 489}, Tuple.Create<SendAsyncSource<TOutput>, Exception>(this, exception), runAsync); 498SendAsyncSource<TOutput> source = (SendAsyncSource<TOutput>)state!; 550state => ((SendAsyncSource<TOutput>)state!).OfferToTarget(), this, 564SendAsyncSource<TOutput>? source = Common.UnwrapWeakReference<SendAsyncSource<TOutput>>(state!); 725CancellationHandler(new WeakReference<SendAsyncSource<TOutput>>(this)); // same code as registered with the CancellationToken 758private readonly SendAsyncSource<TOutput> _source; 762public DebugView(SendAsyncSource<TOutput> source)