2 interfaces inheriting from IDataflowBlock
System.Threading.Tasks.Dataflow (2)
Base\ISourceBlock.cs (1)
20public interface ISourceBlock<out TOutput> : IDataflowBlock
Base\ITargetBlock.cs (1)
17public interface ITargetBlock<in TInput> : IDataflowBlock
69 references to IDataflowBlock
System.Threading.Tasks.Dataflow (69)
Base\DataflowBlock.cs (22)
196Task IDataflowBlock.Completion { get { return _source.Completion; } } 198void IDataflowBlock.Complete() { _target.Complete(); } 200void IDataflowBlock.Fault(Exception exception) { _target.Fault(exception); } 733Task IDataflowBlock.Completion { get { return Task; } } 738void IDataflowBlock.Complete() { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } 740void IDataflowBlock.Fault(Exception exception) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } 1381void IDataflowBlock.Complete() 1387void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 1390Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } } 1558void IDataflowBlock.Complete() 1564void IDataflowBlock.Fault(Exception exception) 1575Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } } 1597/// <see cref="IDataflowBlock"/> implementation delegates to the specified source. 1639void IDataflowBlock.Fault(Exception exception) 2264void IDataflowBlock.Complete() 2270void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 2273Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } } 2774void IDataflowBlock.Complete() { } // No-op 2776void IDataflowBlock.Fault(Exception exception) { } // No-op 2778Task IDataflowBlock.Completion
Blocks\ActionBlock.cs (1)
238void IDataflowBlock.Fault(Exception exception)
Blocks\BatchBlock.cs (3)
83var thisBlock = ((BatchBlock<T>)state!) as IDataflowBlock; 102void IDataflowBlock.Fault(Exception exception)
Blocks\BatchedJoinBlock.cs (8)
101var thisBlock = ((BatchedJoinBlock<T1, T2>)state!) as IDataflowBlock; 157void IDataflowBlock.Fault(Exception exception) 353var thisBlock = ((BatchedJoinBlock<T1, T2, T3>)state!) as IDataflowBlock; 414void IDataflowBlock.Fault(Exception exception) 617void IDataflowBlock.Fault(Exception exception) 633Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } }
Blocks\BroadcastBlock.cs (3)
93var thisBlock = ((BroadcastBlock<T>)state!) as IDataflowBlock; 115void IDataflowBlock.Fault(Exception exception)
Blocks\BufferBlock.cs (3)
75var thisBlock = ((BufferBlock<T>)state!) as IDataflowBlock; 150void IDataflowBlock.Fault(Exception exception)
Blocks\JoinBlock.cs (9)
97var thisBlock = ((JoinBlock<T1, T2>)state!) as IDataflowBlock; 144void IDataflowBlock.Fault(Exception exception) 322var thisBlock = ((JoinBlock<T1, T2, T3>)state!) as IDataflowBlock; 371void IDataflowBlock.Fault(Exception exception) 937void IDataflowBlock.Fault(Exception exception) 1039IDataflowBlock ownerJoin, JoinBlockTargetBase[] targets, 1061internal readonly IDataflowBlock _ownerJoin;
Blocks\TransformBlock.cs (3)
156var thisBlock = ((TransformBlock<TInput, TOutput>)state!) as IDataflowBlock; 336void IDataflowBlock.Fault(Exception exception)
Blocks\TransformManyBlock.cs (3)
152var thisBlock = ((TransformManyBlock<TInput, TOutput>)state!) as IDataflowBlock; 548void IDataflowBlock.Fault(Exception exception)
Blocks\WriteOnceBlock.cs (1)
209void IDataflowBlock.Fault(Exception exception)
Internal\Common.cs (7)
102internal static int GetBlockId(IDataflowBlock block) 118IDataflowBlock block, DataflowBlockOptions? options = null) 384internal static Task? GetPotentiallyNotSupportedCompletionTask(IDataflowBlock block) 546internal static void PropagateCompletion(Task sourceCompletionTask, IDataflowBlock target, Action<Exception>? exceptionHandler) 569private static void PropagateCompletionAsContinuation(Task sourceCompletionTask, IDataflowBlock target) 573sourceCompletionTask.ContinueWith(static (task, state) => Common.PropagateCompletion(task, (IDataflowBlock)state!, AsyncExceptionHandler), 580internal static void PropagateCompletionOnceCompleted(Task sourceCompletionTask, IDataflowBlock target)
Internal\DataflowEtwProvider.cs (3)
64internal void DataflowBlockCreated(IDataflowBlock block, DataflowBlockOptions dataflowBlockOptions) 92IDataflowBlock block, Task task, TaskLaunchedReason reason, int availableMessages) 128internal void DataflowBlockCompleted(IDataflowBlock block)
Internal\TargetRegistry.cs (3)
346Task IDataflowBlock.Completion { get { return _owningSource.Completion; } } 348void IDataflowBlock.Complete() { _target.Complete(); } 350void IDataflowBlock.Fault(Exception exception) { _target.Fault(exception); }