1 instantiation of ReceiveTarget
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
1073var target = new ReceiveTarget<TOutput>();
14 references to ReceiveTarget
System.Threading.Tasks.Dataflow (14)
Base\DataflowBlock.cs (14)
1039return Common.CreateTaskFromException<TOutput>(ReceiveTarget<TOutput>.CreateExceptionForTimeout()); 1073var target = new ReceiveTarget<TOutput>(); 1099ReceiveTarget<TOutput>.CachedLinkingTimerCallback, target, 1106ReceiveTarget<TOutput>.CachedLinkingCancellationCallback, target); // we don't have to cleanup this registration, as this cts is short-lived 1142var receiveTarget = (ReceiveTarget<T>)state!; 1150var receiveTarget = (ReceiveTarget<T>)state!; 1326var target = (ReceiveTarget<T>)state!; 1337var target = (ReceiveTarget<T>)state!; 1358var target = (ReceiveTarget<T>)state!;