DataflowBlock.ReceiveAllAsync<TOutput> 方法

定义

命名空间:

System.Threading.Tasks.Dataflow

程序集:

System.Threading.Tasks.Dataflow.dll

包:

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

Source:

DataflowBlock.IAsyncEnumerable.cs

创建一个 IAsyncEnumerable<T> ，用于从源接收所有数据。

public static System.Collections.Generic.IAsyncEnumerable<TOutput> ReceiveAllAsync<TOutput> (this System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput> source, System.Threading.CancellationToken cancellationToken = default);

static member ReceiveAllAsync : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<'Output> * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<'Output>

<Extension()>
Public Function ReceiveAllAsync(Of TOutput) (source As IReceivableSourceBlock(Of TOutput), Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of TOutput)

类型参数

TOutput

指定源中所包含的数据的类型。

参数

source

IReceivableSourceBlock<TOutput>

要从中异步接收的源。

cancellationToken

CancellationToken

CancellationToken可用于取消接收操作的 。

返回

IAsyncEnumerable<TOutput>

创建的异步可枚举项。

例外

ArgumentNullException

source 为 null。

OperationCanceledException

取消令牌已取消。 此异常存储在返回的任务中。