IPropagatorBlock<TInput,TOutput> 接口

定义

命名空间:

System.Threading.Tasks.Dataflow

程序集:

System.Threading.Tasks.Dataflow.dll

包:

System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

表示同时为数据的目标和源的数据流块。

generic <typename TInput, typename TOutput>
public interface class IPropagatorBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public interface IPropagatorBlock<in TInput,out TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<out TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<in TInput>

type IPropagatorBlock<'Input, 'Output> = interface
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>

Public Interface IPropagatorBlock(Of In TInput, Out TOutput)
Implements ISourceBlock(Of Out TOutput), ITargetBlock(Of In TInput)

类型参数

TInput

指定 IPropagatorBlock<TInput,TOutput> 接受的数据类型。

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

TOutput

指定 IPropagatorBlock<TInput,TOutput> 提供的数据类型。

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

派生

System.Threading.Tasks.Dataflow.BatchBlock<T>

System.Threading.Tasks.Dataflow.BroadcastBlock<T>

System.Threading.Tasks.Dataflow.BufferBlock<T>

System.Threading.Tasks.Dataflow.TransformBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.TransformManyBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.WriteOnceBlock<T>

实现

IDataflowBlock ISourceBlock<TOutput> 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)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	由链接的 ITargetBlock<TInput> 调用，以接受并使用以前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。 (继承自 ISourceBlock<TOutput>)
Fault(Exception)	导致 IDataflowBlock 在 Faulted 状态下完成。 (继承自 IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	将 ISourceBlock<TOutput> 链接到指定的 ITargetBlock<TInput>。 (继承自 ISourceBlock<TOutput>)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	向 ITargetBlock<TInput> 提供消息，向目标提供使用和延迟消息的机会。 (继承自 ITargetBlock<TInput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	由链接的 ITargetBlock<TInput> 调用，以发布由此 DataflowMessageHeader 发布的以前已保留的 ISourceBlock<TOutput>。 (继承自 ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	由链接的 ITargetBlock<TInput> 调用，以保留以前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。 (继承自 ISourceBlock<TOutput>)

扩展方法

AsObservable<TOutput>(ISourceBlock<TOutput>)	在 IObservable<T> 创建新的 ISourceBlock<TOutput> 抽象。
AsObserver<TInput>(ITargetBlock<TInput>)	在 IObserver<T> 创建新的 ITargetBlock<TInput> 抽象。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	将 ISourceBlock<TOutput> 链接到指定的 ITargetBlock<TInput>。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	ISourceBlock<TOutput>使用指定的ITargetBlock<TInput>筛选器将 链接到指定的 。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput>使用指定的ITargetBlock<TInput>筛选器将 链接到指定的 。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	提供可异步监视可利用的输出的源的 Task<TResult> 。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	提供可异步监视可利用的输出的源的 Task<TResult> 。
Post<TInput>(ITargetBlock<TInput>, TInput)	将项发送到 ITargetBlock<TInput> 中。
Receive<TOutput>(ISourceBlock<TOutput>)	同步接收来自指定源的值。
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	同步从指定的数据源中接收值并提供标记来取消操作。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	同步从指定的数据源中接收值，观察可选的超时期限。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	同步从指定的数据源中接收值，提供标记以取消操作并观察可选的超时间隔。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	异步接收来自指定源的值。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	异步从指定的数据源中接收值并提供标记来取消操作。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	异步从指定的数据源中接收值，观察可选的超时期限。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	异步从指定的数据源中接收值，提供标记以取消操作并观察可选的超时间隔。
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	为目标消息块异步提供消息，允许延期。
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	为目标消息块异步提供消息，允许延期。