1 instantiation of SendAsyncSource
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
325source = new SendAsyncSource<TInput>(target, item, cancellationToken);
15 references to SendAsyncSource
System.Threading.Tasks.Dataflow (15)
Base\DataflowBlock.cs (15)
294SendAsyncSource<TInput> source; 344[DebuggerTypeProxy(typeof(SendAsyncSource<>.DebugView))] 406_cancellationCallback, new WeakReference<SendAsyncSource<TOutput>>(this)); 437try { ((SendAsyncSource<TOutput>)state!).TrySetResult(true); } 450try { ((SendAsyncSource<TOutput>)state!).TrySetResult(false); } 462var tuple = (Tuple<SendAsyncSource<TOutput>, Exception>)state!; 465}, Tuple.Create<SendAsyncSource<TOutput>, Exception>(this, exception), runAsync); 474SendAsyncSource<TOutput> source = (SendAsyncSource<TOutput>)state!; 526state => ((SendAsyncSource<TOutput>)state!).OfferToTarget(), this, 540SendAsyncSource<TOutput>? source = Common.UnwrapWeakReference<SendAsyncSource<TOutput>>(state!); 701CancellationHandler(new WeakReference<SendAsyncSource<TOutput>>(this)); // same code as registered with the CancellationToken 734private readonly SendAsyncSource<TOutput> _source; 738public DebugView(SendAsyncSource<TOutput> source)