语言

ITargetBlock<TInput> 接口

定义

表示作为数据目标的数据流块。

generic <typename TInput>
public interface class ITargetBlock : System::Threading::Tasks::Dataflow::IDataflowBlock
public interface ITargetBlock<in TInput> : System.Threading.Tasks.Dataflow.IDataflowBlock
type ITargetBlock<'Input> = interface
    interface IDataflowBlock
Public Interface ITargetBlock(Of In TInput)
Implements IDataflowBlock

类型参数

TInput

指定接受 ITargetBlock<TInput>的数据类型。

这是逆变类型参数。 即,可以使用指定的类型,也可以使用派生程度较低的任何类型。 有关协变和逆变的详细信息,请参阅泛型中的协变和逆变。
派生
实现

属性

名称 说明
Completion

获取一个 Task 表示数据流块的异步操作和完成。

(继承自 IDataflowBlock)

方法

名称 说明
Complete()

信号 IDataflowBlock 表明,它不应接受或生成更多消息,也不应再使用任何推迟的消息。

(继承自 IDataflowBlock)
Fault(Exception)

使状态 IDataflowBlock 完成 Faulted 。

(继承自 IDataflowBlock)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)

向消息提供一条消息 ITargetBlock<TInput>,使目标有机会使用或推迟消息。

扩展方法

名称 说明
AsObserver<TInput>(ITargetBlock<TInput>)

创建一个新的IObserver<T>抽象。ITargetBlock<TInput>

Post<TInput>(ITargetBlock<TInput>, TInput)

将项目发布到 .ITargetBlock<TInput>

SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)

以异步方式向目标消息块提供消息,从而允许推迟。

SendAsync<TInput>(ITargetBlock<TInput>, TInput)

以异步方式向目标消息块提供消息,从而允许推迟。

适用于