TransformManyBlock<TInput,TOutput> 类

定义

命名空间:

System.Threading.Tasks.Dataflow

程序集:

System.Threading.Tasks.Dataflow.dll

提供数据流块，其调用为每个接收的数据提供的 Func<T,TResult> 委托。

generic <typename TInput, typename TOutput>
public ref class TransformManyBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<TInput, TOutput>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public sealed class TransformManyBlock<TInput,TOutput> : System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput,TOutput>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

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

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

Public NotInheritable Class TransformManyBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)

类型参数

TInput

指定通过此 TransformManyBlock<TInput,TOutput> 接收和操作的数据类型。

TOutput

指定此 TransformManyBlock<TInput,TOutput> 生成的数据输出类型。

继承

Object

TransformManyBlock<TInput,TOutput>

实现

IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> 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。

构造函数

TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>)	使用指定的函数初始化新的 TransformManyBlock<TInput,TOutput>。
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	初始化指定函数和 TransformManyBlock<TInput,TOutput> 的新 ExecutionDataflowBlockOptions。
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>)	使用指定的函数初始化新的 TransformManyBlock<TInput,TOutput>。
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>, ExecutionDataflowBlockOptions)	初始化指定函数和 TransformManyBlock<TInput,TOutput> 的新 ExecutionDataflowBlockOptions。

属性

Completion	获取 Task，其表示数据流块的操作和完成。
InputCount	获取等待被此代码块处理的输入项的数目。
OutputCount	获取可从此块中接收的输出项的数量。

方法

Complete()	通知 IDataflowBlock，告知其不应该生成任何更多的消息也不应使用任何更多的延迟消息。
Equals(Object)	确定指定对象是否等于当前对象。 (继承自 Object)
GetHashCode()	作为默认哈希函数。 (继承自 Object)
GetType()	获取当前实例的 Type。 (继承自 Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	将 ISourceBlock<TOutput> 链接到指定的 ITargetBlock<TInput>。
MemberwiseClone()	创建当前 Object 的浅表副本。 (继承自 Object)
ToString()	返回一个字符串，该字符串表示此 IDataflowBlock 实例的格式化名称。
TryReceive(Predicate<TOutput>, TOutput)	从 IReceivableSourceBlock<TOutput> 中尝试同步接收可用输出项。
TryReceiveAll(IList<TOutput>)	从 IReceivableSourceBlock<TOutput> 中尝试同步接收所有可用项。

显式接口实现

IDataflowBlock.Fault(Exception)	导致 IDataflowBlock 在 Faulted 状态下完成。
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	由链接的 ITargetBlock<TInput> 调用，以接受并使用以前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	由链接的 ITargetBlock<TInput> 调用，以发布由此 DataflowMessageHeader 发布的以前已保留的 ISourceBlock<TOutput>。
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	由链接的 ITargetBlock<TInput> 调用，以保留以前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	向 ITargetBlock<TInput> 提供消息，向目标提供使用和延迟消息的机会。

扩展方法

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)	同步从指定的数据源中接收值，提供标记以取消操作并观察可选的超时间隔。
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	创建一个 IAsyncEnumerable<T> 用于接收源中的所有数据。
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)	为目标消息块异步提供消息，允许延期。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	尝试从 ISourceBlock<TOutput> 中同步接收一个项目。