DataflowBlock 类

定义

命名空间:

System.Threading.Tasks.Dataflow

程序集:

System.Threading.Tasks.Dataflow.dll

程序包:

System.Threading.Tasks.Dataflow v11.0.0-rc.1.26425.128

Source:

DataflowBlock.cs

提供一组静态（在 Visual Basic 中共享）方法来处理数据流块。

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

继承

Object

DataflowBlock

方法

名称	说明
AsObservable<TOutput>(ISourceBlock<TOutput>)	创建一个新的IObservable<T>抽象。ISourceBlock<TOutput>
AsObserver<TInput>(ITargetBlock<TInput>)	创建一个新的IObserver<T>抽象。ITargetBlock<TInput>
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	监视三个数据流源，调用所提供的处理程序，以便先为哪个源提供数据。
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	监视三个数据流源，调用所提供的处理程序，以便先为哪个源提供数据。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	监视两个数据流源，调用所提供的处理程序，以便先为哪个源提供数据。
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	监视两个数据流源，调用所提供的处理程序，以便先为哪个源提供数据。
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	将目标和源封装到单个传播器中。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput>使用指定的筛选器链接到指定的ITargetBlock<TInput>。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	ISourceBlock<TOutput>使用指定的筛选器链接到指定的ITargetBlock<TInput>。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	链接到 ISourceBlock<TOutput> 指定的 ITargetBlock<TInput>。
NullTarget<TInput>()	获取一个目标块，该块同步接受提供给它的所有消息并删除它们。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	提供一个 Task<TResult> 异步监视可用输出的源。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	提供一个 Task<TResult> 异步监视可用输出的源。
Post<TInput>(ITargetBlock<TInput>, TInput)	将项目发布到 .ITargetBlock<TInput>
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	同步接收来自指定源的值，并提供用于取消操作的令牌。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	从指定源同步接收值，提供一个令牌来取消操作并观察可选的超时间隔。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	同步接收来自指定源的值，观察可选的超时期限。
Receive<TOutput>(ISourceBlock<TOutput>)	从指定的源同步接收值。
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	创建一个允许从源接收所有数据的项 IAsyncEnumerable<T> 。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	从指定源异步接收值，并提供用于取消操作的令牌。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	从指定源异步接收值，提供一个令牌来取消操作并观察可选的超时间隔。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	从指定源异步接收值，观察可选的超时期限。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	从指定源异步接收值。
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	以异步方式向目标消息块提供消息，从而允许推迟。
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	以异步方式向目标消息块提供消息，从而允许推迟。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	尝试从 . ISourceBlock<TOutput>中同步接收项。