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); } } 1504void IDataflowBlock.Complete() => TrySetResult(false); 1507void IDataflowBlock.Fault(Exception exception) 1518Task IDataflowBlock.Completion => throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); 1540/// <see cref="IDataflowBlock"/> implementation delegates to the specified source. 1582void IDataflowBlock.Fault(Exception exception) 2207void IDataflowBlock.Complete() 2213void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 2216Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } } 2717void IDataflowBlock.Complete() { } // No-op 2719void IDataflowBlock.Fault(Exception exception) { } // No-op 2721Task 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); }