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)
178Task IDataflowBlock.Completion { get { return _source.Completion; } } 180void IDataflowBlock.Complete() { _target.Complete(); } 182void IDataflowBlock.Fault(Exception exception) { _target.Fault(exception); } 709Task IDataflowBlock.Completion { get { return Task; } } 714void IDataflowBlock.Complete() { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } 716void IDataflowBlock.Fault(Exception exception) { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } 1348void IDataflowBlock.Complete() 1354void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 1357Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } } 1471void IDataflowBlock.Complete() => TrySetResult(false); 1474void IDataflowBlock.Fault(Exception exception) 1482Task IDataflowBlock.Completion => throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); 1504/// <see cref="IDataflowBlock"/> implementation delegates to the specified source. 1540void IDataflowBlock.Fault(Exception exception) 2126void IDataflowBlock.Complete() 2132void IDataflowBlock.Fault(Exception exception) { ((IDataflowBlock)this).Complete(); } 2135Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } } 2627void IDataflowBlock.Complete() { } // No-op 2629void IDataflowBlock.Fault(Exception exception) { } // No-op 2631Task IDataflowBlock.Completion
Blocks\ActionBlock.cs (1)
232void 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) 350var thisBlock = ((BatchedJoinBlock<T1, T2, T3>)state!) as IDataflowBlock; 411void IDataflowBlock.Fault(Exception exception) 611void IDataflowBlock.Fault(Exception exception) 624Task IDataflowBlock.Completion { get { throw new NotSupportedException(SR.NotSupported_MemberNotNeeded); } }
Blocks\BroadcastBlock.cs (3)
90var thisBlock = ((BroadcastBlock<T>)state!) as IDataflowBlock; 112void IDataflowBlock.Fault(Exception exception)
Blocks\BufferBlock.cs (3)
72var thisBlock = ((BufferBlock<T>)state!) as IDataflowBlock; 147void IDataflowBlock.Fault(Exception exception)
Blocks\JoinBlock.cs (9)
94var thisBlock = ((JoinBlock<T1, T2>)state!) as IDataflowBlock; 141void IDataflowBlock.Fault(Exception exception) 313var thisBlock = ((JoinBlock<T1, T2, T3>)state!) as IDataflowBlock; 362void IDataflowBlock.Fault(Exception exception) 925void IDataflowBlock.Fault(Exception exception) 1024IDataflowBlock ownerJoin, JoinBlockTargetBase[] targets, 1046internal readonly IDataflowBlock _ownerJoin;
Blocks\TransformBlock.cs (3)
153var thisBlock = ((TransformBlock<TInput, TOutput>)state!) as IDataflowBlock; 333void 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)
206void 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); }