DataflowBlock.ReceiveAllAsync<TOutput> 方法

定义

创建一个允许从源接收所有数据的项 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>

创建的异步可枚举。

例外

sourcenull

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

适用于