ITargetBlock<TInput> 接口
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
表示作为数据目标的数据流块。
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> 接受的数据类型。
这是逆变类型参数。 即,可以使用指定的类型,也可以使用派生程度较低的任何类型。 有关协变和逆变的详细信息,请参阅泛型中的协变和逆变。- 派生
- 实现
注解
注意
TPL 数据流库(System.Threading.Tasks.Dataflow 命名空间)不随 .NET 一起分发。 若要在 Visual Studio 中安装 System.Threading.Tasks.Dataflow 命名空间,请打开项目,选择“项目”菜单中的“管理 NuGet 包”,再在线搜索 System.Threading.Tasks.Dataflow
包。 或者,若要使用 .NET Core CLI 进行安装,请运行 dotnet add package System.Threading.Tasks.Dataflow
。
属性
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) |
为目标消息块异步提供消息,允许延期。 |